[
https://issues.apache.org/jira/browse/AMQ-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653298#comment-16653298
]
ASF subversion and git services commented on AMQ-7077:
------------------------------------------------------
Commit 4dee173962a08dbcb88e33f61ec281209c0b9156 in activemq's branch
refs/heads/master from gtully
[ https://git-wip-us.apache.org/repos/asf?p=activemq.git;h=4dee173 ]
AMQ-7077 AMQ-6421 - tie queue consumer slow flag detection to abort slow
consumer policy, fire advisory when set.
> 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)
