| Log Message: |
Added synconization to the methods that setup connection state so that when an async error is detected, it properly does a full cleanup. Previously subscriptions were not properly cleaned up since they were being setup at the same time as they were being cleaned up.
Also start 1 async exception thread ever since an async exception leads to connection tear down. Subsequent failures do not need additional async threads started.
|
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java