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 435fafec46..4715d022bb 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
@@ -47,6 +47,8 @@ import org.apache.http.client.methods.HttpOptions;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.conn.ClientConnectionManager;
 import org.apache.http.conn.params.ConnRoutePNames;
+import org.apache.http.conn.scheme.PlainSocketFactory;
+import org.apache.http.conn.scheme.Scheme;
 import org.apache.http.entity.ByteArrayEntity;
 import org.apache.http.impl.client.BasicResponseHandler;
 import org.apache.http.impl.client.DefaultHttpClient;
@@ -325,6 +327,11 @@ public class HttpClientTransport extends HttpTransportSupport {
             HttpHost proxy = new HttpHost(getProxyHost(), getProxyPort());
             client.getParams().setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy);
 
+            if (client.getConnectionManager().getSchemeRegistry().get("http") == null) {
+                client.getConnectionManager().getSchemeRegistry().register(
+                    new Scheme("http", getProxyPort(), PlainSocketFactory.getSocketFactory()));
+            }
+
             if(getProxyUser() != null && getProxyPassword() != null) {
                 client.getCredentialsProvider().setCredentials(
                     new AuthScope(getProxyHost(), getProxyPort()),