org.codehaus.activemq.transport.http
Class HttpTransportChannelSupport

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.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()


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