Author: jstrachan Date: Wed Dec 14 09:34:16 2005 New Revision: 356814 URL: http://svn.apache.org/viewcvs?rev=356814&view=rev Log: fixed bug that prevented the initialReconnectDelay value from being changed
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/failover/FailoverTransport.java Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/failover/FailoverTransport.java URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/failover/FailoverTransport.java?rev=356814&r1=356813&r2=356814&view=diff ============================================================================== --- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/failover/FailoverTransport.java (original) +++ incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/failover/FailoverTransport.java Wed Dec 14 09:34:16 2005 @@ -115,6 +115,7 @@ if( connectList.isEmpty() ) { failure = new IOException("No uris available to connect to."); } else { + reconnectDelay = initialReconnectDelay; Iterator iter = connectList.iterator(); for (int i = 0; iter.hasNext() && connectedTransport == null && !disposed; i++) { URI uri = (URI) iter.next(); @@ -126,7 +127,7 @@ restoreTransport(t); } log.debug("Connection established"); - reconnectDelay = 10; + reconnectDelay = initialReconnectDelay; connectedTransportURI = uri; connectedTransport = t; reconnectMutex.notifyAll();