Author: gtully
Date: Mon Jul 4 10:24:20 2011
New Revision: 1142605
URL: http://svn.apache.org/viewvc?rev=1142605&view=rev
Log:
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 - apply the new policy to two test cases
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java?rev=1142605&r1=1142604&r2=1142605&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java
Mon Jul 4 10:24:20 2011
@@ -67,6 +67,9 @@ public class TwoBrokerQueueClientsReconn
}
public void doOneClientReceivesOnly() throws Exception {
+ // allow immediate replay back to origin
+ applyRateLimitNetworkFilter(0);
+
// Bridge brokers
bridgeBrokers(broker1, broker2);
bridgeBrokers(broker2, broker1);
@@ -113,6 +116,9 @@ public class TwoBrokerQueueClientsReconn
}
public void doOneClientReceivesOnlyAfterReconnect() throws Exception {
+ // allow immediate replay back to origin
+ applyRateLimitNetworkFilter(0);
+
// Bridge brokers
bridgeBrokers(broker1, broker2);
bridgeBrokers(broker2, broker1);
|