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

[AMQ-6494] fix check order of close state for onException handler

This commit is contained in:
gtully 2017-04-06 10:22:42 +01:00
parent 0752d840b9
commit 63b2e5c4ea
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1965,7 +1965,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
@Override @Override
public void onException(final IOException error) { public void onException(final IOException error) {
onAsyncException(error); onAsyncException(error);
if (!closing.get() && !closed.get()) { if (!closed.get() && !closing.get()) {
executor.execute(new Runnable() { executor.execute(new Runnable() {
@Override @Override
public void run() { public void run() {