slyfox
Sep 1st, 2011, 01:12 AM
Using the new 1.0.0.RELEASE
Have not really changed much code. Using a basic fan-out exchange much like the example in the doc, producing messages works fine. In my consumer, again just like the example documentation I am getting messages but the queue size is not decreasing, so the consumer is essentially stuck in a loop because it never catches up with the queue. I have tried setting all types of options with the channel transacted and acknowledgement but with no luck. Did not change much code, I only noticed this when I updated to 1.0.0.RELEASE. I know I am missing something simple.
Have not really changed much code. Using a basic fan-out exchange much like the example in the doc, producing messages works fine. In my consumer, again just like the example documentation I am getting messages but the queue size is not decreasing, so the consumer is essentially stuck in a loop because it never catches up with the queue. I have tried setting all types of options with the channel transacted and acknowledgement but with no luck. Did not change much code, I only noticed this when I updated to 1.0.0.RELEASE. I know I am missing something simple.