public class HttpClientTransport extends HttpTransportSupport
Transport
which uses the
Apache HTTP Client
libraryModifier and Type | Field and Description |
---|---|
protected boolean |
canSendCompressed |
static int |
MAX_CLIENT_TIMEOUT |
Constructor and Description |
---|
HttpClientTransport(TextWireFormat wireFormat,
URI remoteUrl) |
Modifier and Type | Method and Description |
---|---|
org.apache.activemq.transport.FutureResponse |
asyncRequest(Object command) |
protected void |
configureMethod(org.apache.http.message.AbstractHttpMessage method) |
protected org.apache.http.conn.ClientConnectionManager |
createClientConnectionManager() |
protected org.apache.http.client.HttpClient |
createHttpClient() |
protected void |
doStart() |
protected void |
doStop(org.apache.activemq.util.ServiceStopper stopper) |
int |
getMinSendAsCompressedSize() |
int |
getReceiveCounter() |
org.apache.http.client.HttpClient |
getReceiveHttpClient() |
org.apache.http.client.HttpClient |
getSendHttpClient() |
int |
getSoTimeout() |
boolean |
isTrace() |
boolean |
isUseCompression() |
void |
oneway(Object command) |
Object |
request(Object command) |
void |
run() |
void |
setMinSendAsCompressedSize(int minSendAsCompressedSize)
Sets the minimum size that must be exceeded on a send before compression is used if
the useCompression option is specified.
|
void |
setReceiveHttpClient(org.apache.http.client.HttpClient receiveHttpClient) |
void |
setSendHttpClient(org.apache.http.client.HttpClient sendHttpClient) |
void |
setSoTimeout(int soTimeout) |
void |
setTrace(boolean trace) |
void |
setUseCompression(boolean useCompression) |
getProxyHost, getProxyPassword, getProxyPort, getProxyUser, getRemoteAddress, getRemoteUrl, getTextWireFormat, setProxyHost, setProxyPassword, setProxyPort, setProxyUser, setTextWireFormat, toString
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
public static final int MAX_CLIENT_TIMEOUT
protected boolean canSendCompressed
public HttpClientTransport(TextWireFormat wireFormat, URI remoteUrl)
public org.apache.activemq.transport.FutureResponse asyncRequest(Object command) throws IOException
IOException
public void oneway(Object command) throws IOException
IOException
public Object request(Object command) throws IOException
request
in interface org.apache.activemq.transport.Transport
request
in class org.apache.activemq.transport.TransportSupport
IOException
public void run()
public org.apache.http.client.HttpClient getSendHttpClient()
public void setSendHttpClient(org.apache.http.client.HttpClient sendHttpClient)
public org.apache.http.client.HttpClient getReceiveHttpClient()
public void setReceiveHttpClient(org.apache.http.client.HttpClient receiveHttpClient)
protected void doStart() throws Exception
doStart
in class org.apache.activemq.transport.TransportThreadSupport
Exception
protected void doStop(org.apache.activemq.util.ServiceStopper stopper) throws Exception
doStop
in class org.apache.activemq.util.ServiceSupport
Exception
protected org.apache.http.client.HttpClient createHttpClient()
protected org.apache.http.conn.ClientConnectionManager createClientConnectionManager()
protected void configureMethod(org.apache.http.message.AbstractHttpMessage method)
public boolean isTrace()
public void setTrace(boolean trace)
public int getReceiveCounter()
public int getSoTimeout()
public void setSoTimeout(int soTimeout)
public void setUseCompression(boolean useCompression)
public boolean isUseCompression()
public int getMinSendAsCompressedSize()
public void setMinSendAsCompressedSize(int minSendAsCompressedSize)
minSendAsCompressedSize
- Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.