consumer_thread.scala revision 3be931d9
1