mirror of https://github.com/apache/activemq.git
No need to clean up connection if it's being closed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382960 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
375469bac7
commit
7f9f040835
|
@ -1580,12 +1580,13 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
|
|||
|
||||
protected void transportFailed(Throwable error){
|
||||
transportFailed.set(true);
|
||||
try{
|
||||
cleanup();
|
||||
}catch(JMSException e){
|
||||
log.warn("Cleanup failed",e);
|
||||
if (!closed.get() && !closing.get()) {
|
||||
try{
|
||||
cleanup();
|
||||
}catch(JMSException e){
|
||||
log.warn("Cleanup failed",e);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void setCopyMessageOnSend(boolean copyMessageOnSend) {
|
||||
|
|
Loading…
Reference in New Issue