/[Apache-SVN]
ViewVC logotype

Revision 382459


Jump to revision: Previous Next
Author: jstrachan
Date: Thu Mar 2 17:56:21 2006 UTC (18 years, 7 months ago)
Changed paths: 7
Log Message:
Patch for AMQ-606 to allow slow consumers to have their old messages discarded. For background to the issue see http://docs.codehaus.org/display/ACTIVEMQ/Slow+Consumers

Provides a way to set a limit on the pending messages to be dispatched to a subscription so that if that limit is reached, old messages are discarded. This will avoid the non-durable topics from getting blocked due to slow consumers


Changed paths

Path Details
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/ConstantPendingMessageLimitStrategy.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingMessageLimitStrategy.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PrefetchRatePendingMessageLimitStrategy.java added

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26