diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java index 8f176a758e..f8fff877fd 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java @@ -99,7 +99,7 @@ public class FailoverTransport implements CompositeTransport { private int maxReconnectAttempts; private int startupMaxReconnectAttempts; private int connectFailures; - private long reconnectDelay = this.initialReconnectDelay; + private long reconnectDelay = -1; private Exception connectionFailure; private boolean firstConnection = true; // optionally always have a backup created @@ -805,7 +805,7 @@ public class FailoverTransport implements CompositeTransport { if (connectList.isEmpty()) { failure = new IOException("No uris available to connect to."); } else { - if (!useExponentialBackOff) { + if (!useExponentialBackOff || reconnectDelay == -1) { reconnectDelay = initialReconnectDelay; } synchronized (backupMutex) {