Index: activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpTransportSupport.java =================================================================== --- activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpTransportSupport.java (revision 487372) +++ activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpTransportSupport.java (working copy) @@ -30,6 +30,8 @@ public abstract class HttpTransportSupport extends TransportThreadSupport { private TextWireFormat textWireFormat; private URI remoteUrl; + private String proxyHost; + private int proxyPort = 8080; public HttpTransportSupport(TextWireFormat textWireFormat, URI remoteUrl) { this.textWireFormat = textWireFormat; @@ -57,4 +59,20 @@ public void setTextWireFormat(TextWireFormat textWireFormat) { this.textWireFormat = textWireFormat; } + + public String getProxyHost() { + return proxyHost; + } + + public void setProxyHost(String proxyHost) { + this.proxyHost = proxyHost; + } + + public int getProxyPort() { + return proxyPort; + } + + public void setProxyPort(int proxyPort) { + this.proxyPort = proxyPort; + } } Index: activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java =================================================================== --- activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java (revision 487372) +++ activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java (working copy) @@ -194,7 +194,11 @@ } protected HttpClient createHttpClient() { - return new HttpClient(); + HttpClient client = new HttpClient(); + if (getProxyHost() != null) { + client.getHostConfiguration().setProxy(getProxyHost(), getProxyPort()); + } + return client; } protected void configureMethod(HttpMethod method) {