Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

increase the max amount of time we wait for reconnect since the default network reconnect delay could be up to 5 seconds 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@423794 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-07-20 06:06:18 +00:00
parent 98a6f181ca
commit 1bcd631bf9
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java
View File

@ -37,6 +37,8 @@ import org.apache.activemq.advisory.ConsumerListener;
import org.apache.activemq.broker.BrokerFactory; import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQQueue;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
@ -48,6 +50,8 @@ import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
*/ */
public class NetworkReconnectTest extends TestCase { public class NetworkReconnectTest extends TestCase {
protected static final Log log = LogFactory.getLog(NetworkReconnectTest.class);
private BrokerService producerBroker; private BrokerService producerBroker;
private BrokerService consumerBroker; private BrokerService consumerBroker;
private ActiveMQConnectionFactory producerConnectionFactory; private ActiveMQConnectionFactory producerConnectionFactory;
@ -182,6 +186,11 @@ public class NetworkReconnectTest extends TestCase {
} }
protected void setUp() throws Exception { protected void setUp() throws Exception {
log.info("===============================================================================");
log.info("Running Test Case: "+getName());
log.info("===============================================================================");
producerConnectionFactory = createProducerConnectionFactory(); producerConnectionFactory = createProducerConnectionFactory();
consumerConnectionFactory = createConsumerConnectionFactory(); consumerConnectionFactory = createConsumerConnectionFactory();
destination = new ActiveMQQueue("RECONNECT.TEST.QUEUE"); destination = new ActiveMQQueue("RECONNECT.TEST.QUEUE");
@ -296,7 +305,7 @@ public class NetworkReconnectTest extends TestCase {
if( consumerCounter.get() > 0 ) { if( consumerCounter.get() > 0 ) {
return; return;
} }
Thread.sleep(50); Thread.sleep(100);
} }
fail("The consumer did not arrive."); fail("The consumer did not arrive.");
} }
@ -306,7 +315,7 @@ public class NetworkReconnectTest extends TestCase {
if( consumerCounter.get() == 0 ) { if( consumerCounter.get() == 0 ) {
return; return;
} }
Thread.sleep(50); Thread.sleep(100);
} }
fail("The consumer did not leave."); fail("The consumer did not leave.");
} }