activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r734766 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
Date Thu, 15 Jan 2009 17:59:41 GMT
Author: dejanb
Date: Thu Jan 15 09:59:41 2009
New Revision: 734766

URL: http://svn.apache.org/viewvc?rev=734766&view=rev
Log:
fix for https://issues.apache.org/activemq/browse/AMQ-2047

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java?rev=734766&r1=734765&r2=734766&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
Thu Jan 15 09:59:41 2009
@@ -204,17 +204,17 @@
                             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);



Mime
View raw message