Switch to using Consumer callbacks rather than QueueingConsumer for better rate limiting when prefetch is high or off.