public abstract class AbstractMQTTSocket extends TransportSupport implements MQTTTransport, BrokerServiceAware
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
brokerService |
protected MQTTInactivityMonitor |
mqttInactivityMonitor |
protected X509Certificate[] |
peerCertificates |
protected MQTTProtocolConverter |
protocolConverter |
protected ReentrantLock |
protocolLock |
protected int |
receiveCounter |
protected String |
remoteAddress |
protected CountDownLatch |
socketTransportStarted |
protected MQTTWireFormat |
wireFormat |
Constructor and Description |
---|
AbstractMQTTSocket(String remoteAddress) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
MQTTInactivityMonitor |
getInactivityMonitor() |
X509Certificate[] |
getPeerCertificates() |
protected MQTTProtocolConverter |
getProtocolConverter() |
int |
getReceiveCounter()
Returns a counter which gets incremented as data is read from the transport.
|
String |
getRemoteAddress() |
MQTTWireFormat |
getWireFormat()
Retrieves the WireFormat instance associated with this Transport instance.
|
abstract void |
handleStopped()
Called when the transport is stopping to allow the dervied classes
a chance to close WebSocket resources.
|
void |
oneway(Object command)
A one way asynchronous send
|
void |
sendToActiveMQ(Command command) |
abstract void |
sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) |
void |
setBrokerService(BrokerService brokerService) |
void |
setPeerCertificates(X509Certificate[] certificates)
Sets the certificates provided by the connected peer.
|
void |
setTransportOptions(Map<String,Object> transportOptions) |
protected boolean |
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
protected ReentrantLock protocolLock
protected volatile MQTTProtocolConverter protocolConverter
protected MQTTWireFormat wireFormat
protected final MQTTInactivityMonitor mqttInactivityMonitor
protected final CountDownLatch socketTransportStarted
protected BrokerService brokerService
protected volatile int receiveCounter
protected final String remoteAddress
protected X509Certificate[] peerCertificates
public AbstractMQTTSocket(String remoteAddress)
public void oneway(Object command) throws IOException
Transport
oneway
in interface Transport
IOException
public void sendToActiveMQ(Command command)
sendToActiveMQ
in interface MQTTTransport
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class ServiceSupport
Exception
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
public abstract void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) throws IOException
sendToMQTT
in interface MQTTTransport
IOException
public abstract void handleStopped() throws IOException
IOException
- if an error occurs during the stop.public MQTTInactivityMonitor getInactivityMonitor()
getInactivityMonitor
in interface MQTTTransport
public MQTTWireFormat getWireFormat()
Transport
getWireFormat
in interface MQTTTransport
getWireFormat
in interface Transport
public String getRemoteAddress()
getRemoteAddress
in interface Transport
public int getReceiveCounter()
Transport
getReceiveCounter
in interface Transport
public X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface MQTTTransport
getPeerCertificates
in interface Transport
public void setPeerCertificates(X509Certificate[] certificates)
Transport
setPeerCertificates
in interface MQTTTransport
setPeerCertificates
in interface Transport
certificates
- the Certificates provided by the peer.public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
protected MQTTProtocolConverter getProtocolConverter()
protected boolean transportStartedAtLeastOnce()
public void setTransportOptions(Map<String,Object> transportOptions)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.