Author: rajdavies
Date: Sun Feb 19 14:15:43 2006
New Revision: 378969
URL: http://svn.apache.org/viewcvs?rev=378969&view=rev
Log:
don't iterate forever in oneWay() if disposed (can cause some tests to hang in
Connection close)
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=378969&r1=378968&r2=378969&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
Sun Feb 19 14:15:43 2006
@@ -305,7 +305,7 @@
synchronized (reconnectMutex) {
// Keep trying until the message is sent.
- for (int i = 0;; i++) {
+ for (int i = 0;!disposed; i++) {
try {
// Wait for transport to be connected.
