consumer_thread.scala revision 4ef102af
1