svn commit: r423793 - /incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java

[chirino]

Author: chirino
Date: Wed Jul 19 23:05:38 2006
New Revision: 423793

URL: http://svn.apache.org/viewvc?rev=423793&view=rev
Log:
increase the max amount of time we wait for reconnect since the default network 
reconnect delay could be up to 5 seconds

Modified:
    
incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java

Modified: 
incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java?rev=423793&r1=423792&r2=423793&view=diff
==============================================================================
--- 
incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java
 (original)
+++ 
incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java
 Wed Jul 19 23:05:38 2006
@@ -37,6 +37,8 @@
 import org.apache.activemq.broker.BrokerFactory;
 import org.apache.activemq.broker.BrokerService;
 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;
 
@@ -48,6 +50,8 @@
  */
 public class NetworkReconnectTest extends TestCase {
 
+       protected static final Log log = 
LogFactory.getLog(NetworkReconnectTest.class);
+       
        private BrokerService producerBroker;
        private BrokerService consumerBroker;
        private ActiveMQConnectionFactory producerConnectionFactory;
@@ -182,6 +186,11 @@
        }
 
        protected void setUp() throws Exception {
+               
+               
log.info("===============================================================================");
+               log.info("Running Test Case: "+getName());
+               
log.info("===============================================================================");
+               
                producerConnectionFactory = createProducerConnectionFactory();
                consumerConnectionFactory = createConsumerConnectionFactory();
                destination = new ActiveMQQueue("RECONNECT.TEST.QUEUE");
@@ -296,7 +305,7 @@
                        if( consumerCounter.get() > 0 ) {
                                return;
                        }
-                       Thread.sleep(50);
+                       Thread.sleep(100);
                }
                fail("The consumer did not arrive.");
        }
@@ -306,7 +315,7 @@
                        if( consumerCounter.get() == 0 ) {
                                return;
                        }
-                       Thread.sleep(50);
+                       Thread.sleep(100);
                }
                fail("The consumer did not leave.");
        }