consumer_thread.scala revision 00bba9f1
1