From e547cbdf4fa70f0e97920b78e8e40b011ef6034f Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Thu, 15 Jan 2009 17:59:41 +0000 Subject: [PATCH] fix for https://issues.apache.org/activemq/browse/AMQ-2047 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@734766 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/transport/fanout/FanoutTransport.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java index f049c34aec..99d04ca7ce 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java @@ -204,17 +204,17 @@ public class FanoutTransport implements CompositeTransport { LOG.debug("Stopped: " + this); LOG.debug("Attempting connect to: " + uri); Transport t = TransportFactory.compositeConnect(uri); - LOG.debug("Connection established"); fanoutHandler.transport = t; - fanoutHandler.reconnectDelay = 10; - fanoutHandler.connectFailures = 0; - if (primary == null) { - primary = fanoutHandler; - } t.setTransportListener(fanoutHandler); if (started) { restoreTransport(fanoutHandler); } + LOG.debug("Connection established"); + fanoutHandler.reconnectDelay = initialReconnectDelay; + fanoutHandler.connectFailures = 0; + if (primary == null) { + primary = fanoutHandler; + } connectedCount++; } catch (Exception e) { LOG.debug("Connect fail to: " + uri + ", reason: " + e);