You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Matt Pavlovich (Jira)" <ji...@apache.org> on 2021/03/18 14:30:00 UTC

[jira] [Closed] (AMQ-5200) Dispatch of messages within JMSXGroupID is affected by maxPageSize

     [ https://issues.apache.org/jira/browse/AMQ-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matt Pavlovich closed AMQ-5200.
-------------------------------
    Resolution: Won't Fix

> 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.8.0, 5.9.0, 5.9.1
>            Reporter: Matt Nathan
>            Assignee: Matt Pavlovich
>            Priority: Major
>
> 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
(v8.3.4#803005)