consumer_thread.scala revision 8d509979
1