org.apache.activemq.transport.stomp
Class StompTransportFilter
java.lang.Object
org.apache.activemq.transport.TransportFilter
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
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 |
StompTransportFilter
public StompTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext)
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
getPeerCertificates
public java.security.cert.X509Certificate[] getPeerCertificates()
- Specified by:
getPeerCertificates
in interface StompTransport
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 java.lang.String getDefaultHeartBeat()
setDefaultHeartBeat
public void setDefaultHeartBeat(java.lang.String defaultHeartBeat)
Copyright © 2005-2012. All Rights Reserved.