added threaded consumer
broken pub/sub