org.activemq.transport.stomp
Class StompTransportChannel

java.lang.Object
  extended byorg.activemq.transport.TransportChannelSupport
      extended byorg.activemq.transport.tcp.TcpTransportChannel
          extended byorg.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 $

Field Summary
 
Fields inherited from class org.activemq.transport.tcp.TcpTransportChannel
dataIn, dataOut, socket
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
StompTransportChannel()
           
StompTransportChannel(Socket socket, Executor executor)
           
StompTransportChannel(TcpTransportServerChannel serverChannel, Socket socket, Executor executor)
           
StompTransportChannel(URI remoteLocation)
           
StompTransportChannel(URI remoteLocation, URI localLocation)
           
 
Method Summary
protected  void doConsumePacket(Packet packet)
          consume a packet from the channel
 StompWireFormat getTTMPWireFormat()
           
protected  void readWireFormat()
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

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
Method Detail

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.