org.codehaus.activemq.transport.http
Class HttpTransportChannel

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

All Implemented Interfaces:

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

public class HttpTransportChannel

extends HttpTransportChannelSupport

Version:

$Revision: 1.3 $

Field Summary

Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport

pendingStop, transportConnected

Constructor Summary

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

Method Summary

void	asyncSend(org.codehaus.activemq.message.Packet packet)
protected void	configureConnection(HttpURLConnection connection)
void	forceDisconnect()
protected HttpURLConnection	getReceiveConnection()
protected HttpURLConnection	getSendConnection()
boolean	isMulticast()
void	run()
void	stop()

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

canProcessWireFormatVersion, getClosed, getCurrentWireFormatVersion, getRemoteUrl, getStarted, getWireFormat, setClientID, setWireFormat, start, startThread, toString

Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport

addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HttpTransportChannel

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

Method Detail

asyncSend

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

Throws:

JMSException

stop

public void stop()

Specified by:

stop in interface org.codehaus.activemq.transport.TransportChannel

Overrides:

stop in class HttpTransportChannelSupport

isMulticast

public boolean isMulticast()

Specified by:

isMulticast in interface org.codehaus.activemq.transport.TransportChannel

Overrides:

isMulticast in class HttpTransportChannelSupport

run

public void run()

getSendConnection

protected HttpURLConnection getSendConnection()
                                       throws IOException

Throws:

IOException

getReceiveConnection

protected HttpURLConnection getReceiveConnection()
                                          throws IOException

Throws:

IOException

configureConnection

protected void configureConnection(HttpURLConnection connection)

forceDisconnect

public void forceDisconnect()