org.activemq.transport.http
Class HttpTransportChannelSupport

java.lang.Object
  extended by org.activemq.transport.TransportChannelSupport
      extended by org.activemq.transport.http.HttpTransportChannelSupport
All Implemented Interfaces:
Runnable, org.activemq.service.Service, org.activemq.transport.TransportChannel
Direct Known Subclasses:
HttpClientTransportChannel, HttpTransportChannel

public abstract class HttpTransportChannelSupport
extends org.activemq.transport.TransportChannelSupport
implements Runnable

Version:
$Revision$

Field Summary
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
HttpTransportChannelSupport(org.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.activemq.io.TextWireFormat getTextWireFormat()
           
 org.activemq.io.WireFormat getWireFormat()
           
 boolean isMulticast()
           
 void setClientID(String clientID)
           
 void setWireFormat(org.activemq.io.TextWireFormat wireFormat)
           
 void start()
           
protected  void startThread()
           
 void stop()
           
 String 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
 
Methods inherited from interface java.lang.Runnable
run
 
Methods inherited from interface org.activemq.transport.TransportChannel
asyncSend, forceDisconnect
 

Constructor Detail

HttpTransportChannelSupport

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

isMulticast

public boolean isMulticast()
Specified by:
isMulticast in interface org.activemq.transport.TransportChannel
Overrides:
isMulticast in class org.activemq.transport.TransportChannelSupport

start

public void start()
           throws JMSException
Specified by:
start in interface org.activemq.service.Service
Specified by:
start in interface org.activemq.transport.TransportChannel
Throws:
JMSException

startThread

protected void startThread()

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 org.activemq.transport.TransportChannelSupport

setClientID

public void setClientID(String clientID)
Specified by:
setClientID in interface org.activemq.transport.TransportChannel
Overrides:
setClientID in class org.activemq.transport.TransportChannelSupport

toString

public String toString()
Overrides:
toString in class Object

canProcessWireFormatVersion

public boolean canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version

Specified by:
canProcessWireFormatVersion in interface org.activemq.transport.TransportChannel
Overrides:
canProcessWireFormatVersion in class org.activemq.transport.TransportChannelSupport
Parameters:
version - the version number to test
Returns:
true if can accept the version

getCurrentWireFormatVersion

public int getCurrentWireFormatVersion()
Specified by:
getCurrentWireFormatVersion in interface org.activemq.transport.TransportChannel
Overrides:
getCurrentWireFormatVersion in class org.activemq.transport.TransportChannelSupport
Returns:
the current version of this wire format

getRemoteUrl

public String getRemoteUrl()

getWireFormat

public org.activemq.io.WireFormat getWireFormat()
Specified by:
getWireFormat in interface org.activemq.transport.TransportChannel
Overrides:
getWireFormat in class org.activemq.transport.TransportChannelSupport

getTextWireFormat

public org.activemq.io.TextWireFormat getTextWireFormat()

setWireFormat

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

getClosed

public SynchronizedBoolean getClosed()

getStarted

public SynchronizedBoolean getStarted()


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