Gary Tully created AMQ-4621:
-------------------------------
Summary: 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
Fix For: 5.9.0
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
