org.activemq.transport.http
Class HttpClientTransportChannel

java.lang.Object
  extended by org.activemq.transport.TransportChannelSupport
      extended by org.activemq.transport.http.HttpTransportChannelSupport
          extended by org.activemq.transport.http.HttpClientTransportChannel
All Implemented Interfaces:
Runnable, org.activemq.service.Service, org.activemq.transport.TransportChannel

public class HttpClientTransportChannel
extends HttpTransportChannelSupport

A HTTP TransportChannel which uses the commons-httpclient library

Version:
$Revision$

Field Summary
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
HttpClientTransportChannel(org.activemq.io.TextWireFormat wireFormat, String remoteUrl)
           
 
Method Summary
 void asyncSend(org.activemq.message.Packet packet)
           
protected  void configureMethod(org.apache.commons.httpclient.HttpMethod method)
           
protected  org.apache.commons.httpclient.HttpClient createHttpClient()
           
 void forceDisconnect()
           
 org.apache.commons.httpclient.HttpClient getReceiveHttpClient()
           
 org.apache.commons.httpclient.HttpClient getSendHttpClient()
           
 boolean isMulticast()
           
 void run()
           
 void setReceiveHttpClient(org.apache.commons.httpclient.HttpClient receiveHttpClient)
           
 void setSendHttpClient(org.apache.commons.httpclient.HttpClient sendHttpClient)
           
 
Methods inherited from class org.activemq.transport.http.HttpTransportChannelSupport
canProcessWireFormatVersion, getClosed, getCurrentWireFormatVersion, getRemoteUrl, getStarted, getTextWireFormat, getWireFormat, setClientID, setWireFormat, start, startThread, stop, toString
 
Methods inherited from class org.activemq.transport.TransportChannelSupport
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setExceptionListener, setNoDelay, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stopExecutor
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

HttpClientTransportChannel

public HttpClientTransportChannel(org.activemq.io.TextWireFormat wireFormat,
                                  String remoteUrl)
Method Detail

asyncSend

public void asyncSend(org.activemq.message.Packet packet)
               throws JMSException
Throws:
JMSException

isMulticast

public boolean isMulticast()
Specified by:
isMulticast in interface org.activemq.transport.TransportChannel
Overrides:
isMulticast in class HttpTransportChannelSupport

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)

createHttpClient

protected org.apache.commons.httpclient.HttpClient createHttpClient()

configureMethod

protected void configureMethod(org.apache.commons.httpclient.HttpMethod method)

forceDisconnect

public void forceDisconnect()


Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.