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, WireFormat wireFormat, BrokerContext brokerContext)
           
 
Method Summary
 String getDefaultHeartBeat()
           
 StompInactivityMonitor getInactivityMonitor()
           
 StompWireFormat getWireFormat()
           
 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 setDefaultHeartBeat(String defaultHeartBeat)
           
 void setInactivityMonitor(StompInactivityMonitor monitor)
           
 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,
                            WireFormat wireFormat,
                            BrokerContext brokerContext)
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)
Specified by:
sendToActiveMQ in interface StompTransport

sendToStomp

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

isTrace

public boolean isTrace()

setTrace

public void setTrace(boolean trace)

getInactivityMonitor

public StompInactivityMonitor getInactivityMonitor()
Specified by:
getInactivityMonitor in interface StompTransport

setInactivityMonitor

public void setInactivityMonitor(StompInactivityMonitor monitor)

getWireFormat

public StompWireFormat getWireFormat()
Specified by:
getWireFormat in interface StompTransport

getDefaultHeartBeat

public String getDefaultHeartBeat()

setDefaultHeartBeat

public void setDefaultHeartBeat(String defaultHeartBeat)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.