public class MQTTTransportFilter extends TransportFilter implements MQTTTransport
next, transportListener
Constructor and Description |
---|
MQTTTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext) |
Modifier and Type | Method and Description |
---|---|
MQTTInactivityMonitor |
getInactivityMonitor() |
X509Certificate[] |
getPeerCertificates() |
MQTTWireFormat |
getWireFormat() |
void |
handleException(IOException e) |
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 |
sendToMQTT(MQTTFrame command) |
void |
setInactivityMonitor(MQTTInactivityMonitor 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, stop
public MQTTTransportFilter(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 MQTTTransport
public void sendToMQTT(MQTTFrame command) throws IOException
sendToMQTT
in interface MQTTTransport
IOException
public X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface MQTTTransport
public boolean isTrace()
public void setTrace(boolean trace)
public MQTTInactivityMonitor getInactivityMonitor()
getInactivityMonitor
in interface MQTTTransport
public void setInactivityMonitor(MQTTInactivityMonitor monitor)
public MQTTWireFormat getWireFormat()
getWireFormat
in interface MQTTTransport
public void handleException(IOException e)
Copyright © 2005–2015. All rights reserved.