public abstract class AbstractMQTTSocket extends org.apache.activemq.transport.TransportSupport implements MQTTTransport, org.apache.activemq.broker.BrokerServiceAware
Modifier and Type | Field and Description |
---|---|
protected org.apache.activemq.broker.BrokerService |
brokerService |
protected MQTTInactivityMonitor |
mqttInactivityMonitor |
protected X509Certificate[] |
peerCertificates |
protected MQTTProtocolConverter |
protocolConverter |
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(org.apache.activemq.util.ServiceStopper stopper) |
MQTTInactivityMonitor |
getInactivityMonitor() |
X509Certificate[] |
getPeerCertificates() |
protected MQTTProtocolConverter |
getProtocolConverter() |
int |
getReceiveCounter() |
String |
getRemoteAddress() |
MQTTWireFormat |
getWireFormat() |
abstract void |
handleStopped()
Called when the transport is stopping to allow the dervied classes
a chance to close WebSocket resources.
|
void |
oneway(Object command) |
void |
sendToActiveMQ(org.apache.activemq.command.Command command) |
abstract void |
sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) |
void |
setBrokerService(org.apache.activemq.broker.BrokerService brokerService) |
void |
setPeerCertificates(X509Certificate[] certificates) |
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 volatile MQTTProtocolConverter protocolConverter
protected MQTTWireFormat wireFormat
protected final MQTTInactivityMonitor mqttInactivityMonitor
protected final CountDownLatch socketTransportStarted
protected org.apache.activemq.broker.BrokerService brokerService
protected volatile int receiveCounter
protected final String remoteAddress
protected X509Certificate[] peerCertificates
public AbstractMQTTSocket(String remoteAddress)
public void oneway(Object command) throws IOException
oneway
in interface org.apache.activemq.transport.Transport
IOException
public void sendToActiveMQ(org.apache.activemq.command.Command command)
sendToActiveMQ
in interface MQTTTransport
protected void doStop(org.apache.activemq.util.ServiceStopper stopper) throws Exception
doStop
in class org.apache.activemq.util.ServiceSupport
Exception
protected void doStart() throws Exception
doStart
in class org.apache.activemq.util.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()
getWireFormat
in interface MQTTTransport
public String getRemoteAddress()
getRemoteAddress
in interface org.apache.activemq.transport.Transport
public int getReceiveCounter()
getReceiveCounter
in interface org.apache.activemq.transport.Transport
public X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface MQTTTransport
public void setPeerCertificates(X509Certificate[] certificates)
setPeerCertificates
in interface MQTTTransport
public void setBrokerService(org.apache.activemq.broker.BrokerService brokerService)
setBrokerService
in interface org.apache.activemq.broker.BrokerServiceAware
protected MQTTProtocolConverter getProtocolConverter()
protected boolean transportStartedAtLeastOnce()
public void setTransportOptions(Map<String,Object> transportOptions)
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.