public class MQTTSocket extends AbstractMQTTSocket implements MQTTCodec.MQTTFrameSink, org.eclipse.jetty.websocket.api.WebSocketListener
brokerService, mqttInactivityMonitor, peerCertificates, protocolConverter, protocolLock, receiveCounter, remoteAddress, socketTransportStarted, wireFormat
Constructor and Description |
---|
MQTTSocket(String remoteAddress) |
Modifier and Type | Method and Description |
---|---|
void |
handleStopped()
Called when the transport is stopping to allow the dervied classes
a chance to close WebSocket resources.
|
void |
onFrame(org.fusesource.mqtt.codec.MQTTFrame mqttFrame) |
void |
onWebSocketBinary(byte[] bytes,
int offset,
int length) |
void |
onWebSocketClose(int arg0,
String arg1) |
void |
onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session) |
void |
onWebSocketError(Throwable arg0) |
void |
onWebSocketText(String arg0) |
void |
sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) |
doStart, doStop, getInactivityMonitor, getPeerCertificates, getProtocolConverter, getReceiveCounter, getRemoteAddress, getWireFormat, oneway, sendToActiveMQ, setBrokerService, setPeerCertificates, setTransportOptions, transportStartedAtLeastOnce
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onException, stop
public MQTTSocket(String remoteAddress)
public void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) throws IOException
sendToMQTT
in interface MQTTTransport
sendToMQTT
in class AbstractMQTTSocket
IOException
public void handleStopped() throws IOException
AbstractMQTTSocket
handleStopped
in class AbstractMQTTSocket
IOException
- if an error occurs during the stop.public void onWebSocketBinary(byte[] bytes, int offset, int length)
onWebSocketBinary
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketClose(int arg0, String arg1)
onWebSocketClose
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketConnect(org.eclipse.jetty.websocket.api.Session session)
onWebSocketConnect
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketError(Throwable arg0)
onWebSocketError
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onWebSocketText(String arg0)
onWebSocketText
in interface org.eclipse.jetty.websocket.api.WebSocketListener
public void onFrame(org.fusesource.mqtt.codec.MQTTFrame mqttFrame)
onFrame
in interface MQTTCodec.MQTTFrameSink
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.