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
- Throws:
JMSException
StompTransportChannel
public StompTransportChannel(URI remoteLocation,
URI localLocation)
throws JMSException
- Throws:
JMSException
StompTransportChannel
public StompTransportChannel(TcpTransportServerChannel serverChannel,
Socket socket,
Executor executor)
throws JMSException
- Throws:
JMSException
StompTransportChannel
public StompTransportChannel(Socket socket,
Executor executor)
throws JMSException
- 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
Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.