public class StompTransportFilter extends TransportFilter implements StompTransport
next, transportListener
Constructor and Description |
---|
StompTransportFilter(Transport next,
org.apache.activemq.wireformat.WireFormat wireFormat,
BrokerContext brokerContext) |
Modifier and Type | Method and Description |
---|---|
long |
getConnectAttemptTimeout() |
String |
getDefaultHeartBeat() |
float |
getHbGracePeriodMultiplier()
Returns the currently configured Read check grace period multiplier.
|
StompInactivityMonitor |
getInactivityMonitor() |
int |
getMaxDataLength() |
long |
getMaxFrameSize() |
StompWireFormat |
getWireFormat() |
boolean |
isTrace() |
void |
onCommand(Object command) |
void |
oneway(Object o) |
void |
sendToActiveMQ(org.apache.activemq.command.Command command) |
void |
sendToStomp(StompFrame command) |
void |
setConnectAttemptTimeout(long timeout) |
void |
setDefaultHeartBeat(String defaultHeartBeat) |
void |
setHbGracePeriodMultiplier(float hbGracePeriodMultiplier)
Sets the read check grace period multiplier.
|
void |
setInactivityMonitor(StompInactivityMonitor monitor) |
void |
setMaxDataLength(int maxDataLength)
Sets the maximum number of bytes that the data portion of a STOMP frame is allowed to
be, any incoming STOMP frame with a data section larger than this value will receive
an error response.
|
void |
setMaxFrameSize(int maxFrameSize) |
void |
setTrace(boolean trace) |
void |
start() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, stop, toString, transportInterupted, transportResumed, updateURIs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
onException
public StompTransportFilter(Transport next, org.apache.activemq.wireformat.WireFormat wireFormat, BrokerContext brokerContext)
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class TransportFilter
Exception
public void oneway(Object o) throws IOException
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onCommand(Object command)
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void sendToActiveMQ(org.apache.activemq.command.Command command)
sendToActiveMQ
in interface StompTransport
public void sendToStomp(StompFrame command) throws IOException
sendToStomp
in interface StompTransport
IOException
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)
public float getHbGracePeriodMultiplier()
public void setHbGracePeriodMultiplier(float hbGracePeriodMultiplier)
hbGracePeriodMultiplier
- the hbGracePeriodMultiplier to setpublic void setMaxDataLength(int maxDataLength)
maxDataLength
- size in bytes of the maximum data portion of a STOMP frame.public int getMaxDataLength()
public void setMaxFrameSize(int maxFrameSize)
public long getMaxFrameSize()
public long getConnectAttemptTimeout()
public void setConnectAttemptTimeout(long timeout)
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.