consumer_thread.scala revision 0f5977d1
1