org.apache.activemq.transport.stomp
Class StompTransportFilter

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.stomp.StompTransportFilter
All Implemented Interfaces:
Service, Transport, TransportListener

public class StompTransportFilter
extends TransportFilter

The StompTransportFilter normally sits on top of a TcpTransport that has been configured with the StompWireFormat and is used to convert STOMP commands to ActiveMQ commands. All of the conversion work is done by delegating to the ProtocolConverter.

Author:
chirino

Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
StompTransportFilter(Transport next, FrameTranslator translator, org.springframework.context.ApplicationContext applicationContext)
           
 
Method Summary
 FrameTranslator getFrameTranslator()
           
 X509Certificate[] getPeerCertificates()
           
 boolean isTrace()
           
 void onCommand(Object command)
          called to process a command
 void oneway(Object o)
          A one way asynchronous send
 void sendToActiveMQ(Command command)
           
 void sendToStomp(StompFrame command)
           
 void setTrace(boolean trace)
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, onException, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

StompTransportFilter

public StompTransportFilter(Transport next,
                            FrameTranslator translator,
                            org.springframework.context.ApplicationContext applicationContext)
Method Detail

oneway

public void oneway(Object o)
            throws IOException
Description copied from interface: Transport
A one way asynchronous send

Specified by:
oneway in interface Transport
Overrides:
oneway in class TransportFilter
Throws:
IOException

onCommand

public void onCommand(Object command)
Description copied from interface: TransportListener
called to process a command

Specified by:
onCommand in interface TransportListener
Overrides:
onCommand in class TransportFilter

sendToActiveMQ

public void sendToActiveMQ(Command command)

sendToStomp

public void sendToStomp(StompFrame command)
                 throws IOException
Throws:
IOException

getFrameTranslator

public FrameTranslator getFrameTranslator()

getPeerCertificates

public X509Certificate[] getPeerCertificates()

isTrace

public boolean isTrace()

setTrace

public void setTrace(boolean trace)


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.