From c18b583020cdf97b545586ead7c3ccdcb57523f3 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Wed, 19 Mar 2008 15:52:36 +0000 Subject: [PATCH] Don't timeout a stop since that can lead to a failover connection not being able to reconnect correctly. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638891 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/broker/TransportConnection.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java index 55ba224e35..843f7570f1 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java @@ -876,8 +876,8 @@ public class TransportConnection implements Connection, Task, CommandVisitor { } 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."); } }