activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1356868 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/InitalReconnectDelayTest.java
Date Tue, 03 Jul 2012 19:04:50 GMT
Author: tabish
Date: Tue Jul  3 19:04:49 2012
New Revision: 1356868

URL: http://svn.apache.org/viewvc?rev=1356868&view=rev
Log:
The start time needs to be set before stopping broker1 in order to account for context switching
that can cause the failover process to start before the current call to track the failover
start time. 

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

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/InitalReconnectDelayTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/InitalReconnectDelayTest.java?rev=1356868&r1=1356867&r2=1356868&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/InitalReconnectDelayTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/InitalReconnectDelayTest.java
Tue Jul  3 19:04:49 2012
@@ -16,6 +16,16 @@
  */
 package org.apache.activemq.transport.failover;
 
+import static org.junit.Assert.assertTrue;
+
+import java.util.Date;
+import java.util.concurrent.CountDownLatch;
+
+import javax.jms.Connection;
+import javax.jms.MessageProducer;
+import javax.jms.Queue;
+import javax.jms.Session;
+
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
 import org.junit.After;
@@ -24,15 +34,6 @@ import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.jms.Connection;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import java.util.Date;
-import java.util.concurrent.CountDownLatch;
-
-import static org.junit.Assert.assertTrue;
-
 public class InitalReconnectDelayTest {
 
     private static final transient Logger LOG = LoggerFactory.getLogger(InitalReconnectDelayTest.class);
@@ -59,17 +60,16 @@ public class InitalReconnectDelayTest {
 
         //Halt the broker1...
         LOG.info("Stopping the Broker1...");
+        start = (new Date()).getTime();
         broker1.stop();
 
         LOG.info("Attempting to send... failover should kick in...");
-        start = (new Date()).getTime();
         producer.send(session.createTextMessage("TEST"));
         end = (new Date()).getTime();
 
         //Inital reconnection should kick in and be darned close to what we expected
         LOG.info("Failover took " + (end - start) + " ms.");
         assertTrue("Failover took " + (end - start) + " ms and should be > 14000.", (end
- start) > 14000);
-
     }
 
     @Before



Mime
View raw message