activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1079324 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
Date Tue, 08 Mar 2011 11:16:11 GMT
Author: dejanb
Date: Tue Mar  8 11:16:11 2011
New Revision: 1079324

URL: http://svn.apache.org/viewvc?rev=1079324&view=rev
Log:
give FailoverClusterTest a bit more time to reconnect

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java?rev=1079324&r1=1079323&r2=1079324&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
Tue Mar  8 11:16:11 2011
@@ -52,7 +52,7 @@ public class FailoverClusterTest extends
         if (brokerB == null) {
             brokerB = createBrokerB(BROKER_B_BIND_ADDRESS);
         }
-        Thread.sleep(3000);
+        Thread.sleep(5000);
         Set<String> set = new HashSet<String>();
         for (ActiveMQConnection c : connections) {
             set.add(c.getTransportChannel().getRemoteAddress());
@@ -66,7 +66,7 @@ public class FailoverClusterTest extends
             // add in server side only url param, should not be propagated
             brokerB = createBrokerB(BROKER_B_BIND_ADDRESS + "?transport.closeAsync=false");
         }
-        Thread.sleep(3000);
+        Thread.sleep(5000);
         Set<String> set = new HashSet<String>();
         for (ActiveMQConnection c : connections) {
             set.add(c.getTransportChannel().getRemoteAddress());



Mime
View raw message