after the consumer finished everything on the queue it stops, i want it to continue listening for new message