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

Fix for https://issues.apache.org/activemq/browse/AMQ-1451 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@646354 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-04-09 13:56:47 +00:00
parent 456c1b157b
commit cec77fd12a
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -198,7 +198,7 @@ public class FailoverTransport implements CompositeTransport {
synchronized (reconnectMutex) {
boolean reconnectOk = false;
if(started) {
LOG.warn("Transport failed, attempting to automatically reconnect due to: " + e);
LOG.warn("Transport failed to " + connectedTransportURI+ " , attempting to automatically reconnect due to: " + e);
LOG.debug("Transport failed with the following exception:", e);
reconnectOk = true;
}
@ -207,7 +207,6 @@ public class FailoverTransport implements CompositeTransport {
failedConnectTransportURI=connectedTransportURI;
connectedTransportURI = null;
connected=false;
if(reconnectOk) {
reconnectTask.wakeup();
}
@ -396,7 +395,9 @@ public class FailoverTransport implements CompositeTransport {
// Wait for transport to be connected.
Transport transport = connectedTransport.get();
while (transport == null && !disposed && connectionFailure == null) {
while (transport == null && !disposed
&& connectionFailure == null
&& !Thread.currentThread().isInterrupted()) {
LOG.trace("Waiting for transport to reconnect.");
try {
reconnectMutex.wait(1000);