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 2022/03/31 17:42:00 UTC

[jira] [Updated] (AMQ-5625) Allow AbortSlowConsumerStrategy to specify a fixed number of pending messages to consider a consumer slow

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

Matt Pavlovich updated AMQ-5625:
--------------------------------
    Fix Version/s: 5.18.0
                       (was: 5.17.1)

> Allow AbortSlowConsumerStrategy to specify a fixed number of pending messages to consider a consumer slow
> ---------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-5625
>                 URL: https://issues.apache.org/jira/browse/AMQ-5625
>             Project: ActiveMQ
>          Issue Type: Improvement
>          Components: Broker
>    Affects Versions: 5.8.0
>            Reporter: Tim Bain
>            Priority: Major
>             Fix For: 5.18.0
>
>
> Currently, the AbortSlowConsumerStrategy considers a consumer to be slow when the broker has a number of pending messages equal to the consumer's prefetch buffer size.
> It would be useful to be able to specify directly the number of messages that must be pending to consider the consumer slow, irrespective of the consumer's prefetch size.
> This would be especially useful for consumers with a very small prefetch size (e.g. 1), to allow them to meaningfully use the AbortSlowConsumerStrategy instead of being forced to use the AbortSlowAckConsumerStrategy (which protects against a very different kind of problem).  But it would also be useful for consumers with larger prefetch buffers if we want to consider the consumer slow sooner than the point where there are an additional prefetch buffer worth of pending message; this is especially true for anyone using the default prefetch size of 32k messages for non-persistent topics.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)