activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r956570 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTcpTest.java
Date Mon, 21 Jun 2010 13:14:07 GMT
Author: dejanb
Date: Mon Jun 21 13:14:06 2010
New Revision: 956570

URL: http://svn.apache.org/viewvc?rev=956570&view=rev
Log:
intermittent failures on slow machines

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTcpTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTcpTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTcpTest.java?rev=956570&r1=956569&r2=956570&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTcpTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTcpTest.java
Mon Jun 21 13:14:06 2010
@@ -59,6 +59,7 @@ implements ExceptionListener, TransportL
         connector = broker.addConnector("tcp://localhost:0?transport.useInactivityMonitor=false");
         broker.setPersistent(false);
         broker.start();
+        broker.waitUntilStarted();
         
         class SlowCloseSocketTcpTransportFactory extends TcpTransportFactory {
 
@@ -130,6 +131,7 @@ implements ExceptionListener, TransportL
     
     public void tearDown() throws Exception {
         broker.stop();
+        broker.waitUntilStopped();
     }
 
     protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
@@ -175,6 +177,7 @@ implements ExceptionListener, TransportL
        LOG.info("Transport listener exception:" + error);
        if (reconnectInTransportListener) {
            try {
+               TimeUnit.MILLISECONDS.sleep(500);
                makeConsumer();
            } catch (Exception e) {
                reconnectException = e;



Mime
View raw message