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, StompTransport, Transport, TransportListener

public class StompTransportFilter
extends TransportFilter
implements StompTransport

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, BrokerContext brokerContext)
           
 
Method Summary
 FrameTranslator getFrameTranslator()
           
 java.security.cert.X509Certificate[] getPeerCertificates()
           
 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, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed, updateURIs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.transport.stomp.StompTransport
onException
 

Constructor Detail

StompTransportFilter

public StompTransportFilter(Transport next,
                            FrameTranslator translator,
                            BrokerContext brokerContext)
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)
Specified by:
sendToActiveMQ in interface StompTransport

sendToStomp

public void sendToStomp(StompFrame command)
                 throws java.io.IOException
Specified by:
sendToStomp in interface StompTransport
Throws:
java.io.IOException

getFrameTranslator

public FrameTranslator getFrameTranslator()

getPeerCertificates

public java.security.cert.X509Certificate[] getPeerCertificates()
Specified by:
getPeerCertificates in interface StompTransport

isTrace

public boolean isTrace()

setTrace

public void setTrace(boolean trace)


Copyright © 2005-2012. All Rights Reserved.