From 373417c0df0a2d96b204226eb971360ac39ad558 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Tue, 8 Mar 2011 11:16:11 +0000 Subject: [PATCH] give FailoverClusterTest a bit more time to reconnect git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1079324 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/transport/failover/FailoverClusterTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java b/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java index 80de199f07..f043ee930e 100644 --- a/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java @@ -52,7 +52,7 @@ public class FailoverClusterTest extends TestCase { if (brokerB == null) { brokerB = createBrokerB(BROKER_B_BIND_ADDRESS); } - Thread.sleep(3000); + Thread.sleep(5000); Set set = new HashSet(); for (ActiveMQConnection c : connections) { set.add(c.getTransportChannel().getRemoteAddress()); @@ -66,7 +66,7 @@ public class FailoverClusterTest extends TestCase { // 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 set = new HashSet(); for (ActiveMQConnection c : connections) { set.add(c.getTransportChannel().getRemoteAddress());