consumer_thread.scala revision f8ba67c4
1