Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Bosanac Dejan 2009-01-15 17:59:41 +00:00
parent 2d0fa5e415
commit e547cbdf4f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
View File

@ -204,17 +204,17 @@ public class FanoutTransport implements CompositeTransport {
LOG.debug("Stopped: " + this); LOG.debug("Stopped: " + this);
LOG.debug("Attempting connect to: " + uri); LOG.debug("Attempting connect to: " + uri);
Transport t = TransportFactory.compositeConnect(uri); Transport t = TransportFactory.compositeConnect(uri);
LOG.debug("Connection established");
fanoutHandler.transport = t; fanoutHandler.transport = t;
fanoutHandler.reconnectDelay = 10;
fanoutHandler.connectFailures = 0;
if (primary == null) {
primary = fanoutHandler;
}
t.setTransportListener(fanoutHandler); t.setTransportListener(fanoutHandler);
if (started) { if (started) {
restoreTransport(fanoutHandler); restoreTransport(fanoutHandler);
} }
LOG.debug("Connection established");
fanoutHandler.reconnectDelay = initialReconnectDelay;
fanoutHandler.connectFailures = 0;
if (primary == null) {
primary = fanoutHandler;
}
connectedCount++; connectedCount++;
} catch (Exception e) { } catch (Exception e) {
LOG.debug("Connect fail to: " + uri + ", reason: " + e); LOG.debug("Connect fail to: " + uri + ", reason: " + e);