Author: jstrachan
Date: Wed Mar 15 06:14:29 2006
New Revision: 386076
URL: http://svn.apache.org/viewcvs?rev=386076&view=rev
Log:
catch interupted exceptions
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=386076&r1=386075&r2=386076&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Wed Mar 15 06:14:29 2006
@@ -322,7 +322,12 @@
// Wait for transport to be connected.
while (connectedTransport == null && !disposed &&
connectionFailure==null ) {
log.debug("Waiting for transport to reconnect.");
- reconnectMutex.wait(1000);
+ try {
+ reconnectMutex.wait(1000);
+ }
+ catch (InterruptedException e) {
+ log.debug("Interupted: " + e, e);
+ }
}
if( connectedTransport==null ) {
