Consume from queue in same thread

We can't pass connection object to different greentheads safely.