[
https://issues.apache.org/jira/browse/AMQ-4621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Bish reopened AMQ-4621:
-------------------------------
Reopen while I investigate attached test cases
> Provide a polling SlowConsumerPolicy that uses LastAck time on a sub
> --------------------------------------------------------------------
>
> Key: AMQ-4621
> URL: https://issues.apache.org/jira/browse/AMQ-4621
> Project: ActiveMQ
> Issue Type: Improvement
> Affects Versions: 5.8.0
> Reporter: Gary Tully
> Assignee: Timothy Bish
> Labels: abort, connection, consumer, policy, slowConsumers
> Fix For: 5.9.0
>
> Attachments: AMQ4621Patch.txt, AMQFreezeTest-5.8.0.redhat-60029.zip,
> kahaPendingMEssage-20130905.zip, kahaPendingMEssage-20130906.zip
>
>
> The existing AbortSlowConsumer policy is event driven. It depends on a
> consumer slow event that is triggered when the prefetch is reached and there
> are subsequent dispatches.
> With prefetch=0|1 there still needs to be throughput to determine that the
> consumer is slow so one message can be pending if there are no new messages
> to sent to the destination.
> Providing an alternative implementation that will periodically poll consumers
> for their last ack time will be more deterministic. The slow advisory may
> never fire, but the consumer will get aborted if it does not ack in a timely
> manner.
> if lastAckTime exceeds the max and there are dispatched messages it can be a
> candidate for removal.
> Optionally lastAckTime exceeding and no dispatched messages can be a way to
> remove idle consumers. Not sure if that is necessary.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
