public class StompTransportFilter extends TransportFilter implements StompTransport
next, transportListener
Constructor and Description |
---|
StompTransportFilter(Transport next,
FrameTranslator translator,
BrokerContext brokerContext) |
Modifier and Type | Method and Description |
---|---|
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) |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed, updateURIs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
onException
public StompTransportFilter(Transport next, FrameTranslator translator, BrokerContext brokerContext)
public void oneway(java.lang.Object o) throws java.io.IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
java.io.IOException
public void onCommand(java.lang.Object command)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void sendToActiveMQ(Command command)
sendToActiveMQ
in interface StompTransport
public void sendToStomp(StompFrame command) throws java.io.IOException
sendToStomp
in interface StompTransport
java.io.IOException
public FrameTranslator getFrameTranslator()
public java.security.cert.X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface StompTransport
public boolean isTrace()
public void setTrace(boolean trace)
Copyright © 2005-2012. All Rights Reserved.