consumer_thread.scala revision 9595dab4
1