Repository: activemq Updated Branches: refs/heads/master 0752d840b -> 63b2e5c4e
[AMQ-6494] fix check order of close state for onException handler Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/63b2e5c4 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/63b2e5c4 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/63b2e5c4 Branch: refs/heads/master Commit: 63b2e5c4eabfbdc54ff6ebb155092f7033e7bf22 Parents: 0752d84 Author: gtully <[email protected]> Authored: Thu Apr 6 10:22:42 2017 +0100 Committer: gtully <[email protected]> Committed: Thu Apr 6 10:23:16 2017 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/activemq/ActiveMQConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/63b2e5c4/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java index 8e6c157..b55f411 100644 --- a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java +++ b/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java @@ -1965,7 +1965,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon @Override public void onException(final IOException error) { onAsyncException(error); - if (!closing.get() && !closed.get()) { + if (!closed.get() && !closing.get()) { executor.execute(new Runnable() { @Override public void run() {
