org.activemq.transport.http
Class HttpTransportChannel

java.lang.Object
  org.activemq.transport.TransportChannelSupport
      org.activemq.transport.http.HttpTransportChannelSupport
          org.activemq.transport.http.HttpTransportChannel

All Implemented Interfaces:

Runnable, org.activemq.service.Service, org.activemq.transport.TransportChannel

Direct Known Subclasses:

HttpsTransportChannel

public class HttpTransportChannel
extends HttpTransportChannelSupport

Version:

$Revision$

Field Summary

Fields inherited from class org.activemq.transport.TransportChannelSupport

cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally

Constructor Summary

HttpTransportChannel(org.activemq.io.TextWireFormat wireFormat, String remoteUrl)

Method Summary

void	asyncSend(org.activemq.message.Packet packet)
protected void	configureConnection(HttpURLConnection connection)
protected HttpURLConnection	createReceiveConnection()
protected HttpURLConnection	createSendConnection()
void	forceDisconnect()
protected HttpURLConnection	getReceiveConnection()
protected URL	getRemoteURL()
protected HttpURLConnection	getSendConnection()
boolean	isMulticast()
void	run()
protected void	setReceiveConnection(HttpURLConnection conn)
protected void	setSendConnection(HttpURLConnection conn)
void	stop()

Methods inherited from class org.activemq.transport.http.HttpTransportChannelSupport

canProcessWireFormatVersion, getClosed, getCurrentWireFormatVersion, getRemoteUrl, getStarted, getTextWireFormat, getWireFormat, setClientID, setWireFormat, start, startThread, 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

HttpTransportChannel

public HttpTransportChannel(org.activemq.io.TextWireFormat wireFormat,
                            String remoteUrl)
                     throws MalformedURLException

Throws:

MalformedURLException

Method Detail

asyncSend

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

Throws:

JMSException

stop

public void stop()

Specified by:

stop in interface org.activemq.service.Service

Specified by:

stop in interface org.activemq.transport.TransportChannel

Overrides:

stop in class HttpTransportChannelSupport

isMulticast

public boolean isMulticast()

Specified by:

isMulticast in interface org.activemq.transport.TransportChannel

Overrides:

isMulticast in class HttpTransportChannelSupport

run

public void run()

createSendConnection

protected HttpURLConnection createSendConnection()
                                          throws IOException

Throws:

IOException

createReceiveConnection

protected HttpURLConnection createReceiveConnection()
                                             throws IOException

Throws:

IOException

configureConnection

protected void configureConnection(HttpURLConnection connection)

getRemoteURL

protected URL getRemoteURL()

getSendConnection

protected HttpURLConnection getSendConnection()
                                       throws IOException

Throws:

IOException

getReceiveConnection

protected HttpURLConnection getReceiveConnection()
                                          throws IOException

Throws:

IOException

setSendConnection

protected void setSendConnection(HttpURLConnection conn)

setReceiveConnection

protected void setReceiveConnection(HttpURLConnection conn)

forceDisconnect

public void forceDisconnect()