org.codehaus.activemq.transport.http
Class HttpTransportChannelSupport

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

All Implemented Interfaces:

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

Direct Known Subclasses:

HttpClientTransportChannel, HttpTransportChannel

public abstract class HttpTransportChannelSupport

extends org.codehaus.activemq.transport.TransportChannelSupport

implements Runnable

Version:

$Revision: 1.2 $

Field Summary

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

pendingStop, transportConnected

Constructor Summary

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

Method Summary

boolean	canProcessWireFormatVersion(int version) Can this wireformat process packets of this version
SynchronizedBoolean	getClosed()
int	getCurrentWireFormatVersion()
String	getRemoteUrl()
SynchronizedBoolean	getStarted()
org.codehaus.activemq.io.TextWireFormat	getWireFormat()
boolean	isMulticast()
void	setClientID(String clientID)
void	setWireFormat(org.codehaus.activemq.io.TextWireFormat wireFormat)
void	start()
protected void	startThread()
void	stop()
String	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

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface org.codehaus.activemq.transport.TransportChannel

asyncSend, forceDisconnect

Constructor Detail

HttpTransportChannelSupport

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

Method Detail

isMulticast

public boolean isMulticast()

Specified by:

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

start

public void start()
           throws JMSException

Specified by:

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

Throws:

JMSException

startThread

protected void startThread()

stop

public void stop()

Specified by:

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

setClientID

public void setClientID(String clientID)

Specified by:

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

toString

public String toString()

canProcessWireFormatVersion

public boolean canProcessWireFormatVersion(int version)

Can this wireformat process packets of this version

Specified by:

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

Parameters:

version - the version number to test

Returns:

true if can accept the version

getCurrentWireFormatVersion

public int getCurrentWireFormatVersion()

Specified by:

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

Returns:

the current version of this wire format

getRemoteUrl

public String getRemoteUrl()

getWireFormat

public org.codehaus.activemq.io.TextWireFormat getWireFormat()

setWireFormat

public void setWireFormat(org.codehaus.activemq.io.TextWireFormat wireFormat)

getClosed

public SynchronizedBoolean getClosed()

getStarted

public SynchronizedBoolean getStarted()