svn commit: r638891 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

[chirino]

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.");
         }
     }