consumer_thread.scala revision 2be4980a
1