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:
- Runnable, Service, Transport
- Direct Known Subclasses:
- HttpsClientTransport
public class HttpClientTransport
- extends HttpTransportSupport
A HTTP org.apache.activemq.transport.TransportChannel
which uses the
commons-httpclient
library
- Version:
- $Revision$
Methods inherited from class org.apache.activemq.transport.TransportSupport |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, onException, reconnect, request, setTransportListener |
MAX_CLIENT_TIMEOUT
public static final int MAX_CLIENT_TIMEOUT
- See Also:
- Constant Field Values
HttpClientTransport
public HttpClientTransport(TextWireFormat wireFormat,
URI remoteUrl)
asyncRequest
public FutureResponse asyncRequest(Object command)
throws IOException
- Throws:
IOException
oneway
public void oneway(Object command)
throws IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Throws:
IOException
request
public Object request(Object command)
throws 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:
IOException
run
public void run()
getSendHttpClient
public HttpClient getSendHttpClient()
setSendHttpClient
public void setSendHttpClient(HttpClient sendHttpClient)
getReceiveHttpClient
public HttpClient getReceiveHttpClient()
setReceiveHttpClient
public void setReceiveHttpClient(HttpClient receiveHttpClient)
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class TransportThreadSupport
- Throws:
Exception
doStop
protected void doStop(ServiceStopper stopper)
throws Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
Exception
createHttpClient
protected HttpClient createHttpClient()
configureMethod
protected void configureMethod(HttpMethod method)
isTrace
public boolean isTrace()
setTrace
public void setTrace(boolean trace)
getReceiveCounter
public int getReceiveCounter()
- Description copied from interface:
Transport
- Returns a counter which gets incremented as data is read from the transport.
It should only be used to determine if there is progress being made in reading the next command from the transport.
The value may wrap into the negative numbers.
- Returns:
- a counter which gets incremented as data is read from the transport.
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.