/[Apache-SVN]

Revision 1504231

Jump to revision:
Author:	tabish
Date:	Wed Jul 17 18:44:27 2013 UTC (11 years, 3 months ago)
Changed paths:	11
Log Message:	Fix for: https://issues.apache.org/jira/browse/AMQ-4621 New SlowConsumerStrategy implementation for aborting consumers that haven't ack'd in the configured interval. Can also be used to kick idle consumers if you disable the ignore idle consumers option.

Changed paths

Path	Details
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Subscription.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java	added
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java	modified , text changed
activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/SlowConsumerStrategy.java	modified , text changed
activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowAckConsumerTest.java	added
activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumerTest.java	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26