It looks like the internal queue is populated with messages prefetched from the RMQ queue, but once empty returns None, and this internal queue doesn't receive any more messages from the RMQ queue.
To loop through all messages in a queue, the prefetch count has to be set to the number of messages in the queue - which varys isn't aware of.
It looks like the internal queue is populated with messages prefetched from the RMQ queue, but once empty returns None, and this internal queue doesn't receive any more messages from the RMQ queue.
To loop through all messages in a queue, the prefetch count has to be set to the number of messages in the queue - which varys isn't aware of.