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).
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java