[ 
https://issues.apache.org/jira/browse/AMQ-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653248#comment-16653248
 ] 

Simon Lundstrom commented on AMQ-7077:
--------------------------------------

As I said on IRC, to be able to configure the criteria that ActiveMQ uses to 
mark a consumer as slow would be awesome. maxTimeSinceLastAck is probably what 
we would use.

> Queue subscriber view slowConsumer flag set in error
> ----------------------------------------------------
>
>                 Key: AMQ-7077
>                 URL: https://issues.apache.org/jira/browse/AMQ-7077
>             Project: ActiveMQ
>          Issue Type: Bug
>    Affects Versions: 5.15.0
>            Reporter: Gary Tully
>            Assignee: Gary Tully
>            Priority: Major
>             Fix For: 5.16.0
>
>
> For queue subscribers, the broker dispatches prefetch num messages and stops. 
> The subscription is considered full.
> There is currently logic in PrefetchSubscription that flags the consumer as 
> slow on the success full dispatch of the last message in a prefetch batch. 
> this flag remains set till there are more messages to dispatch, which happens 
> on the first ack.
> The consumer is considered slow, till it acks (which seems wrong) and in the 
> case that there are no more message to dispatch, it remains slow.
>  
> Interestingly, there are some tests for this functionality that only validate 
> topics in error.
>  
> From my investigation, it seems that for queue consumers, it is really only 
> possible to gauge slowness due to the frequency of acks, which is what the 
> AbortAckSlowConsumerPolicy does.
> It makes sense that that code flags a consumer as slow once it is detected as 
> such.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to