activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r638891 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Date Wed, 19 Mar 2008 15:52:36 GMT
Author: chirino
Date: Wed Mar 19 08:52:36 2008
New Revision: 638891

URL: http://svn.apache.org/viewvc?rev=638891&view=rev
Log:
Don't timeout a stop since that can lead to a failover connection not being able to reconnect
correctly.

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?rev=638891&r1=638890&r2=638891&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Wed Mar 19 08:52:36 2008
@@ -876,8 +876,8 @@
     }
     public void stop() throws Exception {
         stopAsync();
-        if( !stopped.await(10, TimeUnit.SECONDS) ) {
-            LOG.info("Could not shutdown the connection to '" + transport.getRemoteAddress()+
"' in a timely manner.");
+        while( !stopped.await(5, TimeUnit.SECONDS) ) {
+            LOG.info("The connection to '" + transport.getRemoteAddress()+ "' is taking a
long time to shutdown.");
         }
     }
     



Mime
View raw message