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

Further change for https://issues.apache.org/activemq/browse/AMQ-1771 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@663691 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-06-05 18:11:46 +00:00
parent e40e2ac67a
commit 60d4d48fbf
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -694,7 +694,7 @@ public class FailoverTransport implements CompositeTransport {
try { try {
//if it isn't set after 2secs - it //if it isn't set after 2secs - it
//probably never will be //probably never will be
listenerMutex.wait(2000); listenerMutex.wait(2000);
}catch(InterruptedException ex) {} }catch(InterruptedException ex) {}
} }
} }
@ -725,11 +725,12 @@ public class FailoverTransport implements CompositeTransport {
// Make sure on initial startup, that the transportListener has been initialized // Make sure on initial startup, that the transportListener has been initialized
// for this instance. // for this instance.
while(transportListener == null) { synchronized(listenerMutex) {
try { if (transportListener==null) {
Thread.sleep(100); try {
listenerMutex.wait(2000);
}catch(InterruptedException ex) {}
} }
catch(InterruptedException iEx) {}
} }