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, Service, TransportChannel
- Direct Known Subclasses:
- HttpClientTransportChannel, HttpTransportChannel
- public abstract class HttpTransportChannelSupport
- extends TransportChannelSupport
- implements Runnable
- Version:
- $Revision: 1.3 $
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, send, send, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor |
Methods inherited from interface java.lang.Runnable |
run |
HttpTransportChannelSupport
public HttpTransportChannelSupport(TextWireFormat wireFormat,
String remoteUrl)
isMulticast
public boolean isMulticast()
- Specified by:
isMulticast
in interface TransportChannel
- Returns:
- true if this transport is multicast based (i.e. broadcasts to multiple nodes)
start
public void start()
throws JMSException
- Description copied from interface:
TransportChannel
- start listeneing for events
- Specified by:
start
in interface TransportChannel
- Throws:
JMSException
- if an error occurs
startThread
protected void startThread()
stop
public void stop()
- Description copied from class:
TransportChannelSupport
- close the channel
- Specified by:
stop
in interface TransportChannel
- Overrides:
stop
in class TransportChannelSupport
setClientID
public void setClientID(String clientID)
- Description copied from interface:
TransportChannel
- Provides a way to specify the client ID that this channel is using
- Specified by:
setClientID
in interface TransportChannel
- Overrides:
setClientID
in class TransportChannelSupport
- Parameters:
clientID
- set the clientID
toString
public String toString()
canProcessWireFormatVersion
public boolean canProcessWireFormatVersion(int version)
- Can this wireformat process packets of this version
- Specified by:
canProcessWireFormatVersion
in interface TransportChannel
- Parameters:
version
- the version number to test
- Returns:
- true if can accept the version
getCurrentWireFormatVersion
public int getCurrentWireFormatVersion()
- Specified by:
getCurrentWireFormatVersion
in interface TransportChannel
- Returns:
- the current version of this wire format
getRemoteUrl
public String getRemoteUrl()
getWireFormat
public TextWireFormat getWireFormat()
setWireFormat
public void setWireFormat(TextWireFormat wireFormat)
getClosed
public SynchronizedBoolean getClosed()
getStarted
public SynchronizedBoolean getStarted()
Copyright © 2004 Protique, Ltd.. All Rights Reserved.