mirror of https://github.com/apache/activemq.git
catch interupted exceptions
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386076 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
a2fc7a2dc0
commit
9c19776c17
|
@ -322,8 +322,13 @@ public class FailoverTransport implements CompositeTransport {
|
|||
// Wait for transport to be connected.
|
||||
while (connectedTransport == null && !disposed && connectionFailure==null ) {
|
||||
log.debug("Waiting for transport to reconnect.");
|
||||
try {
|
||||
reconnectMutex.wait(1000);
|
||||
}
|
||||
catch (InterruptedException e) {
|
||||
log.debug("Interupted: " + e, e);
|
||||
}
|
||||
}
|
||||
|
||||
if( connectedTransport==null ) {
|
||||
// Previous loop may have exited due to use being
|
||||
|
|
Loading…
Reference in New Issue