activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1142605 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java
Date Mon, 04 Jul 2011 10:24:20 GMT
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);



Mime
View raw message