org.apache.activemq.transport.http
Class HttpClientTransport
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.transport.TransportSupport
org.apache.activemq.transport.TransportThreadSupport
org.apache.activemq.transport.http.HttpTransportSupport
org.apache.activemq.transport.http.HttpClientTransport
- All Implemented Interfaces:
- java.lang.Runnable, Service, Transport
public class HttpClientTransport
- extends HttpTransportSupport
A HTTP org.apache.activemq.transport.TransportChannel
which uses the commons-httpclient
library
- Version:
- $Revision$
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
MAX_CLIENT_TIMEOUT
public static final int MAX_CLIENT_TIMEOUT
- See Also:
- Constant Field Values
HttpClientTransport
public HttpClientTransport(TextWireFormat wireFormat,
java.net.URI remoteUrl)
asyncRequest
public FutureResponse asyncRequest(java.lang.Object command)
throws java.io.IOException
- Throws:
java.io.IOException
oneway
public void oneway(java.lang.Object command)
throws java.io.IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Throws:
java.io.IOException
request
public java.lang.Object request(java.lang.Object command)
throws java.io.IOException
- Description copied from interface:
Transport
- A synchronous request response
- Specified by:
request
in interface Transport
- Overrides:
request
in class TransportSupport
- Returns:
- the response
- Throws:
java.io.IOException
run
public void run()
getSendHttpClient
public org.apache.commons.httpclient.HttpClient getSendHttpClient()
setSendHttpClient
public void setSendHttpClient(org.apache.commons.httpclient.HttpClient sendHttpClient)
getReceiveHttpClient
public org.apache.commons.httpclient.HttpClient getReceiveHttpClient()
setReceiveHttpClient
public void setReceiveHttpClient(org.apache.commons.httpclient.HttpClient receiveHttpClient)
doStart
protected void doStart()
throws java.lang.Exception
- Overrides:
doStart
in class TransportThreadSupport
- Throws:
java.lang.Exception
doStop
protected void doStop(ServiceStopper stopper)
throws java.lang.Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
java.lang.Exception
createHttpClient
protected org.apache.commons.httpclient.HttpClient createHttpClient()
configureMethod
protected void configureMethod(org.apache.commons.httpclient.HttpMethod method)
isTrace
public boolean isTrace()
setTrace
public void setTrace(boolean trace)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.