svn commit: r734766 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java

[dejanb]

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);