mirror of https://github.com/apache/activemq.git
apply patch for https://issues.apache.org/activemq/browse/AMQ-2472 with thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@831827 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
97d7c390df
commit
763ef103d8
|
@ -18,7 +18,6 @@ package org.apache.activemq;
|
|||
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import java.util.concurrent.atomic.AtomicLong;
|
||||
|
||||
import javax.jms.ConnectionFactory;
|
||||
import javax.jms.ExceptionListener;
|
||||
|
|
|
@ -30,15 +30,12 @@ import org.apache.activemq.util.IdGenerator;
|
|||
import org.apache.activemq.util.ServiceStopper;
|
||||
import org.apache.commons.httpclient.HttpClient;
|
||||
import org.apache.commons.httpclient.HttpMethod;
|
||||
import org.apache.commons.httpclient.HttpMethodRetryHandler;
|
||||
import org.apache.commons.httpclient.HttpStatus;
|
||||
import org.apache.commons.httpclient.NoHttpResponseException;
|
||||
import org.apache.commons.httpclient.methods.GetMethod;
|
||||
import org.apache.commons.httpclient.methods.HeadMethod;
|
||||
import org.apache.commons.httpclient.methods.InputStreamRequestEntity;
|
||||
import org.apache.commons.httpclient.methods.PostMethod;
|
||||
import org.apache.commons.httpclient.params.HttpClientParams;
|
||||
import org.apache.commons.httpclient.params.HttpMethodParams;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
||||
|
@ -199,7 +196,9 @@ public class HttpClientTransport extends HttpTransportSupport {
|
|||
}
|
||||
|
||||
protected void doStop(ServiceStopper stopper) throws Exception {
|
||||
httpMethod.abort();
|
||||
if (httpMethod != null) {
|
||||
httpMethod.abort();
|
||||
}
|
||||
}
|
||||
|
||||
protected HttpClient createHttpClient() {
|
||||
|
|
Loading…
Reference in New Issue