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

Add a check to the iterate() so that on failover - it's not possible 

to iterate for ever if the transport has actually been stopped

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@373862 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2006-01-31 16:31:21 +00:00
parent 815b6c5d87
commit 3e7ebc2368
1 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
View File

@ -170,22 +170,21 @@ public class FailoverTransport implements CompositeTransport {
} }
} }
if(!disposed){
try { try{
log.debug("Waiting " + reconnectDelay + " ms before attempting connection. "); log.debug("Waiting "+reconnectDelay+" ms before attempting connection. ");
Thread.sleep(reconnectDelay); Thread.sleep(reconnectDelay);
}catch(InterruptedException e1){
Thread.currentThread().interrupt();
}
if(useExponentialBackOff){
// Exponential increment of reconnect delay.
reconnectDelay*=backOffMultiplier;
if(reconnectDelay>maxReconnectDelay)
reconnectDelay=maxReconnectDelay;
}
} }
catch (InterruptedException e1) { return !disposed;
Thread.currentThread().interrupt();
}
if (useExponentialBackOff) {
// Exponential increment of reconnect delay.
reconnectDelay *= backOffMultiplier;
if (reconnectDelay > maxReconnectDelay)
reconnectDelay = maxReconnectDelay;
}
return true;
} }
}); });