make ConsumerListener from thread