org.apache.activemq.transport.http
Class HttpClientTransport

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.transport.TransportSupport
          extended by org.apache.activemq.transport.TransportThreadSupport
              extended by org.apache.activemq.transport.http.HttpTransportSupport
                  extended by 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$

Field Summary
static int MAX_CLIENT_TIMEOUT
           
 
Constructor Summary
HttpClientTransport(TextWireFormat wireFormat, java.net.URI remoteUrl)
           
 
Method Summary
 FutureResponse asyncRequest(java.lang.Object command)
           
protected  void configureMethod(org.apache.commons.httpclient.HttpMethod method)
           
protected  org.apache.commons.httpclient.HttpClient createHttpClient()
           
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 org.apache.commons.httpclient.HttpClient getReceiveHttpClient()
           
 org.apache.commons.httpclient.HttpClient getSendHttpClient()
           
 boolean isTrace()
           
 void oneway(java.lang.Object command)
          A one way asynchronous send
 java.lang.Object request(java.lang.Object command)
          A synchronous request response
 void run()
           
 void setReceiveHttpClient(org.apache.commons.httpclient.HttpClient receiveHttpClient)
           
 void setSendHttpClient(org.apache.commons.httpclient.HttpClient sendHttpClient)
           
 void setTrace(boolean trace)
           
 
Methods inherited from class org.apache.activemq.transport.http.HttpTransportSupport
getProxyHost, getProxyPort, getRemoteAddress, getRemoteUrl, getTextWireFormat, setProxyHost, setProxyPort, setTextWireFormat, toString
 
Methods inherited from class org.apache.activemq.transport.TransportThreadSupport
isDaemon, setDaemon
 
Methods inherited from class org.apache.activemq.transport.TransportSupport
asyncRequest, checkStarted, doConsume, getTransportListener, narrow, onException, request, setTransportListener
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
dispose, isStarted, isStopped, isStopping, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Field Detail

MAX_CLIENT_TIMEOUT

public static final int MAX_CLIENT_TIMEOUT
See Also:
Constant Field Values
Constructor Detail

HttpClientTransport

public HttpClientTransport(TextWireFormat wireFormat,
                           java.net.URI remoteUrl)
Method Detail

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.