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 coversion 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)
           
 
Method Summary
 FrameTranslator getFrameTranslator()
           
 boolean isTrace()
           
 void onCommand(java.lang.Object command)
          called to process a command
 void oneway(java.lang.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, getRemoteAddress, getTransportListener, narrow, onException, 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)
Method Detail

oneway

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

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

onCommand

public void onCommand(java.lang.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 java.io.IOException
Throws:
java.io.IOException

getFrameTranslator

public FrameTranslator getFrameTranslator()

isTrace

public boolean isTrace()

setTrace

public void setTrace(boolean trace)


Copyright © 2009 Apache Software Foundation. All Rights Reserved.