mirror of https://github.com/apache/activemq.git
https://issues.apache.org/jira/browse/AMQ-2774 - handling TransportDisposedIOException and making reconnection logic work in this case as well
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1094618 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
fc2d54866e
commit
eb24079a93
|
@ -133,8 +133,6 @@ public class DiscoveryNetworkConnector extends NetworkConnector implements Disco
|
|||
try {
|
||||
bridge.start();
|
||||
bridges.put(uri, bridge);
|
||||
} catch (TransportDisposedIOException e) {
|
||||
LOG.warn("Network bridge between: " + localURI + " and: " + uri + " was correctly stopped before it was correctly started.");
|
||||
} catch (Exception e) {
|
||||
ServiceSupport.dispose(localTransport);
|
||||
ServiceSupport.dispose(remoteTransport);
|
||||
|
@ -145,7 +143,6 @@ public class DiscoveryNetworkConnector extends NetworkConnector implements Disco
|
|||
} catch (IOException e1) {
|
||||
LOG.debug("Discovery agent failure while handling failure event: " + e1.getMessage(), e1);
|
||||
}
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue