diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java index da8ee6602d..30c0695c66 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java @@ -1144,7 +1144,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon * @throws JMSException */ public void asyncSendPacket(Command command) throws JMSException { - if (isClosed() || closing.get()) { + if (isClosed()) { throw new ConnectionClosedException(); } else { doAsyncSendPacket(command);