Matt Nathan created AMQ-5200:
--------------------------------

             Summary: Dispatch of messages within JMSXGroupID is affected by 
maxPageSize
                 Key: AMQ-5200
                 URL: https://issues.apache.org/jira/browse/AMQ-5200
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.9.1, 5.9.0, 5.8.0
            Reporter: Matt Nathan


When you have multiple consumers for a single queue and are using JMSXGroupID 
on each message, when one of the consumers is slow the in-memory messages held 
in the Queue in the broker will eventually get filled up with messages that 
only the slow consumer can handle. This means that no other messages are 
delivered as only the in-memory collection is checked for messages awaiting 
dispatch.

The size of the in-memory collection is controlled by the maxPageSize parameter.

Additionally (and the cause of much confusion in our setup) the expired message 
scheduled task, which runs every 30s by default, will page in more than 
maxPageSize messages, causing additional non-slow messages to be available for 
dispatch. This results in what appeared to be a 30s bursting of messages sent 
to all non-slow consumers.

https://issues.apache.org/jira/browse/AMQ-2217 - the same issue but talks about 
message selectors instead of JMSXGroupID
http://stackoverflow.com/q/23810807/317404 - my question on StackOverflow



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Reply via email to