/[Apache-SVN]

Revision 1142005

Jump to revision:
Author:	gtully
Date:	Fri Jul 1 17:45:54 2011 UTC (13 years, 3 months ago)
Changed paths:	16
Log Message:	https://issues.apache.org/jira/browse/AMQ-2484,https://issues.apache.org/jira/browse/AMQ-2324: Forwarded message cannot be distributed to the original broker, Avoid stuck messages in a network of brokers - implement destination policy that allows the network filter factory to be provided. A new implementation will allow queues to replay messages with a configurable delay once there are no local consumers. Also it allows a rate limit on the network consumer such that a statically included dest does not consume all messages if there is a slow local consumer

Changed paths

Path	Details
activemq/trunk/activemq-core/pom.xml	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/CompositeDemandForwardingBridge.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConditionalNetworkBridgeFilterFactory.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DefaultNetworkBridgeFilterFactory.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandSubscription.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkBridgeFilterFactory.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsMultipleBrokersTestSupport.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/BrokerNetworkWithStuckMessagesTest.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkRestartTest.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26