org.apache.activemq.transport.ws

Class AbstractMQTTSocket

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportSupport

org.apache.activemq.transport.ws.AbstractMQTTSocket

All Implemented Interfaces:

BrokerServiceAware, Service, MQTTTransport, Transport

Direct Known Subclasses:

MQTTSocket

public abstract class AbstractMQTTSocket
extends TransportSupport
implements MQTTTransport, BrokerServiceAware

Field Summary

Fields

Modifier and Type	Field and Description
protected BrokerService	brokerService
protected MQTTInactivityMonitor	mqttInactivityMonitor
protected X509Certificate[]	peerCertificates
protected MQTTProtocolConverter	protocolConverter
protected int	receiveCounter
protected String	remoteAddress
protected CountDownLatch	socketTransportStarted
protected MQTTWireFormat	wireFormat

Constructor Summary

Constructors

Constructor and Description
AbstractMQTTSocket(String remoteAddress)

Method Summary

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()
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)
void	setTransportOptions(Map<String,Object> transportOptions)
protected boolean	transportStartedAtLeastOnce()

Methods inherited from class org.apache.activemq.transport.TransportSupport

asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs

Methods inherited from class org.apache.activemq.util.ServiceSupport

addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.transport.mqtt.MQTTTransport

onException, stop

Methods inherited from interface org.apache.activemq.Service

start, stop

Field Detail

protocolConverter

protected volatile MQTTProtocolConverter protocolConverter

wireFormat

protected MQTTWireFormat wireFormat

mqttInactivityMonitor

protected final MQTTInactivityMonitor mqttInactivityMonitor

socketTransportStarted

protected final CountDownLatch socketTransportStarted

brokerService

protected BrokerService brokerService

receiveCounter

protected volatile int receiveCounter

remoteAddress

protected final String remoteAddress

peerCertificates

protected X509Certificate[] peerCertificates

Constructor Detail

AbstractMQTTSocket

public AbstractMQTTSocket(String remoteAddress)

Method Detail

oneway

public void oneway(Object command)
            throws IOException

Description copied from interface: Transport

A one way asynchronous send

Specified by:

oneway in interface Transport

Throws:

IOException

sendToActiveMQ

public void sendToActiveMQ(Command command)

Specified by:

sendToActiveMQ in interface MQTTTransport

doStop

protected void doStop(ServiceStopper stopper)
               throws Exception

Specified by:

doStop in class ServiceSupport

Throws:

Exception

doStart

protected void doStart()
                throws Exception

Specified by:

doStart in class ServiceSupport

Throws:

Exception

sendToMQTT

public abstract void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command)
                         throws IOException

Specified by:

sendToMQTT in interface MQTTTransport

Throws:

IOException

handleStopped

public abstract void handleStopped()
                            throws IOException

Called when the transport is stopping to allow the dervied classes a chance to close WebSocket resources.

Throws:

IOException - if an error occurs during the stop.

getInactivityMonitor

public MQTTInactivityMonitor getInactivityMonitor()

Specified by:

getInactivityMonitor in interface MQTTTransport

getWireFormat

public MQTTWireFormat getWireFormat()

Specified by:

getWireFormat in interface MQTTTransport

getRemoteAddress

public String getRemoteAddress()

Specified by:

getRemoteAddress in interface Transport

Returns:

the remote address for this connection

getReceiveCounter

public int getReceiveCounter()

Description copied from interface: Transport

Returns a counter which gets incremented as data is read from the transport. It should only be used to determine if there is progress being made in reading the next command from the transport. The value may wrap into the negative numbers.

Specified by:

getReceiveCounter in interface Transport

Returns:

a counter which gets incremented as data is read from the transport.

getPeerCertificates

public X509Certificate[] getPeerCertificates()

Specified by:

getPeerCertificates in interface MQTTTransport

setPeerCertificates

public void setPeerCertificates(X509Certificate[] certificates)

Specified by:

setPeerCertificates in interface MQTTTransport

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware

getProtocolConverter

protected MQTTProtocolConverter getProtocolConverter()

transportStartedAtLeastOnce

protected boolean transportStartedAtLeastOnce()

setTransportOptions

public void setTransportOptions(Map<String,Object> transportOptions)