diff --git a/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java b/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java index c5bcc5ce61..435fafec46 100755 --- a/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java +++ b/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java @@ -303,7 +303,7 @@ public class HttpClientTransport extends HttpTransportSupport { abortThread.start(); abortThread.join(2000); - if (!abortThread.isAlive()) { + if (abortThread.isAlive() && !httpMethod.isAborted()) { abortThread.interrupt(); } }