I do not receive messages in my second consumer
FAQ > Errors > I do not receive messages in my second consumer
Scenario
- You send 100 messages to a queue.
- Start consumer A, it receives the message
- You start another consumer B, it doesn’t receive any messages.
- You kill A.
- Consumer B receives messages now, why?
Answer
This is to do with prefetch buffers.
ActiveMQ Classic will try and deliver a number of messages to each consumer as soon as possible to achieve maximum throughput. That means that each consumer typically has 100-1000 messages in RAM ready to be processed so that there is no latency waiting for another message to arrive under periods of high throughput of messages.
The problem is, if consumer A is set with a prefetch value of >= 100 then it will receive all of the messages before consumer B starts. Then when B starts there are actually no messages available to be dispatched to B (since they are all dispatched to A) until either
- new messages are sent to the queue
- consumer A stops or its JVM dies
The solution to this problem is to configure the pre-fetch value to something smaller - such as 1, start the consumers together or publish the messages after the consumers have started.
You can also change the dispatch policy to ensure round robin dispatch.
To help diagnose these kinds of issues, try JMX or the Web Console
