consumer_thread.scala revision 3ee6c0a8
1