org.activemq.transport.stomp
Class StompTransportChannel
java.lang.Object
org.activemq.transport.TransportChannelSupport
org.activemq.transport.tcp.TcpTransportChannel
org.activemq.transport.stomp.StompTransportChannel
- All Implemented Interfaces:
- Runnable, Service, TransportChannel
- public class StompTransportChannel
- extends TcpTransportChannel
A transport for using Stomp to talk to ActiveMQ
- Version:
- $Revision: 1.1 $
Methods inherited from class org.activemq.transport.tcp.TcpTransportChannel |
asyncSend, canProcessWireFormatVersion, closeStreams, createSocket, createSocket, doAsyncSend, doClose, forceDisconnect, getCurrentWireFormatVersion, getSocket, getSocketBufferSize, getSoTimeout, initialiseSocket, initializeStreams, isClosed, isMulticast, isUseAsyncSend, run, setNoDelay, setSocketBufferSize, setSoTimeout, setUseAsyncSend, start, stop, toString |
Methods inherited from class org.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, asyncSendWithReceipt, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, getWireFormat, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stopExecutor |
StompTransportChannel
public StompTransportChannel()
StompTransportChannel
public StompTransportChannel(URI remoteLocation)
throws JMSException
StompTransportChannel
public StompTransportChannel(URI remoteLocation,
URI localLocation)
throws JMSException
StompTransportChannel
public StompTransportChannel(TcpTransportServerChannel serverChannel,
Socket socket,
Executor executor)
throws JMSException
StompTransportChannel
public StompTransportChannel(Socket socket,
Executor executor)
throws JMSException
getTTMPWireFormat
public StompWireFormat getTTMPWireFormat()
readWireFormat
protected void readWireFormat()
throws JMSException,
IOException
- Overrides:
readWireFormat
in class TcpTransportChannel
- Throws:
JMSException
IOException
doConsumePacket
protected void doConsumePacket(Packet packet)
- Description copied from class:
TransportChannelSupport
- consume a packet from the channel
- Overrides:
doConsumePacket
in class TransportChannelSupport
- Parameters:
packet
-
Copyright © 2004-2007 Protique, Ltd.. All Rights Reserved.