consumer_thread.scala revision 09e4df88
1