Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #158

This commit is contained in:
Timothy Bish 2015-11-19 13:14:26 -05:00
parent cf5735320f 934f3cea7e
commit d730e35f9d
1 changed files with 26 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -678,6 +678,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
this.activeTempDestinations.clear();
try {
if (isConnectionInfoSentToBroker) {
// If we announced ourselves to the broker.. Try to let the broker
// know that the connection is being shutdown.
@ -694,7 +695,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
}
doAsyncSendPacket(new ShutdownInfo());
}
} finally { // release anyway even if previous communication fails
started.set(false);
// TODO if we move the TaskRunnerFactory to the connection
@ -708,6 +709,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
closing.set(false);
}
}
}
} finally {
try {
if (executor != null) {