Call transportFailed() only for IOException caused by the transport. Async exceptions from the broker could just mean that an async operation failed (like an async send).

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@376339 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-02-09 16:29:30 +00:00
parent 4f6e90108f
commit 40926586aa
1 changed files with 1 additions and 1 deletions

View File

@ -1329,13 +1329,13 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
} else {
log.warn("Async exception with no exception listener: " + error, error);
}
transportFailed(error);
}
}
public void onException(IOException error) {
onAsyncException(error);
transportFailed(error);
ServiceSupport.dispose(this.transport);
brokerInfoReceived.countDown();
}