Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> transport >> [ stomp overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

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:

java.lang.Runnable, org.activemq.service.Service, org.activemq.transport.TransportChannel

---

public class StompTransportChannel

extends org.activemq.transport.tcp.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(java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.Executor executor)

StompTransportChannel(org.activemq.transport.tcp.TcpTransportServerChannel serverChannel, java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.Executor executor)

StompTransportChannel(java.net.URI remoteLocation)

StompTransportChannel(java.net.URI remoteLocation, java.net.URI localLocation)

 

Method Summary
protected  void	doConsumePacket(org.activemq.message.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(java.net.URI remoteLocation)
                      throws javax.jms.JMSException

---

StompTransportChannel

public StompTransportChannel(java.net.URI remoteLocation,
                             java.net.URI localLocation)
                      throws javax.jms.JMSException

---

StompTransportChannel

public StompTransportChannel(org.activemq.transport.tcp.TcpTransportServerChannel serverChannel,
                             java.net.Socket socket,
                             EDU.oswego.cs.dl.util.concurrent.Executor executor)
                      throws javax.jms.JMSException

---

StompTransportChannel

public StompTransportChannel(java.net.Socket socket,
                             EDU.oswego.cs.dl.util.concurrent.Executor executor)
                      throws javax.jms.JMSException

Method Detail

getTTMPWireFormat

public StompWireFormat getTTMPWireFormat()

---

readWireFormat

protected void readWireFormat()
                       throws javax.jms.JMSException,
                              java.io.IOException

---

doConsumePacket

protected void doConsumePacket(org.activemq.message.Packet packet)

Description copied from class: org.activemq.transport.TransportChannelSupport

consume a packet from the channel

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> transport >> [ stomp overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---