public class StompTransportFilter extends TransportFilter implements StompTransport
next, transportListener
Constructor and Description |
---|
StompTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext) |
Modifier and Type | Method and Description |
---|---|
String |
getDefaultHeartBeat() |
StompInactivityMonitor |
getInactivityMonitor() |
X509Certificate[] |
getPeerCertificates() |
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) |
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, WireFormat wireFormat, BrokerContext brokerContext)
public void oneway(Object o) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onCommand(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 IOException
sendToStomp
in interface StompTransport
IOException
public X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface StompTransport
public boolean isTrace()
public void setTrace(boolean trace)
public StompInactivityMonitor getInactivityMonitor()
getInactivityMonitor
in interface StompTransport
public void setInactivityMonitor(StompInactivityMonitor monitor)
public StompWireFormat getWireFormat()
getWireFormat
in interface StompTransport
public String getDefaultHeartBeat()
public void setDefaultHeartBeat(String defaultHeartBeat)
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.