org.apache.activemq.transport.ws

Class MQTTSocket

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportSupport

org.apache.activemq.transport.ws.MQTTSocket

All Implemented Interfaces:

BrokerServiceAware, Service, MQTTTransport, Transport, org.eclipse.jetty.websocket.WebSocket, org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage

public class MQTTSocket
extends TransportSupport
implements org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage, MQTTTransport, BrokerServiceAware

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.websocket.WebSocket

org.eclipse.jetty.websocket.WebSocket.Connection, org.eclipse.jetty.websocket.WebSocket.FrameConnection, org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage, org.eclipse.jetty.websocket.WebSocket.OnControl, org.eclipse.jetty.websocket.WebSocket.OnFrame, org.eclipse.jetty.websocket.WebSocket.OnTextMessage

Constructor Summary

Constructors

Constructor and Description
MQTTSocket()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop(ServiceStopper stopper)
MQTTInactivityMonitor	getInactivityMonitor()
java.security.cert.X509Certificate[]	getPeerCertificates()
int	getReceiveCounter() Returns a counter which gets incremented as data is read from the transport.
java.lang.String	getRemoteAddress()
MQTTWireFormat	getWireFormat()
void	onClose(int closeCode, java.lang.String message)
void	oneway(java.lang.Object command) A one way asynchronous send
void	onMessage(byte[] bytes, int offset, int length)
void	onOpen(org.eclipse.jetty.websocket.WebSocket.Connection connection)
void	sendToActiveMQ(Command command)
void	sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command)
void	setBrokerService(BrokerService brokerService)

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

Constructor Detail

MQTTSocket

public MQTTSocket()

Method Detail

onMessage

public void onMessage(byte[] bytes,
             int offset,
             int length)

Specified by:

onMessage in interface org.eclipse.jetty.websocket.WebSocket.OnBinaryMessage

onOpen

public void onOpen(org.eclipse.jetty.websocket.WebSocket.Connection connection)

Specified by:

onOpen in interface org.eclipse.jetty.websocket.WebSocket

onClose

public void onClose(int closeCode,
           java.lang.String message)

Specified by:

onClose in interface org.eclipse.jetty.websocket.WebSocket

doStart

protected void doStart()
                throws java.lang.Exception

Specified by:

doStart in class ServiceSupport

Throws:

java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception

Specified by:

doStop in class ServiceSupport

Throws:

java.lang.Exception

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.

getRemoteAddress

public java.lang.String getRemoteAddress()

Specified by:

getRemoteAddress in interface Transport

Returns:

the remote address for this connection

oneway

public void oneway(java.lang.Object command)
            throws java.io.IOException

Description copied from interface: Transport

A one way asynchronous send

Specified by:

oneway in interface Transport

Throws:

java.io.IOException

sendToActiveMQ

public void sendToActiveMQ(Command command)

Specified by:

sendToActiveMQ in interface MQTTTransport

sendToMQTT

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

Specified by:

sendToMQTT in interface MQTTTransport

Throws:

java.io.IOException

getPeerCertificates

public java.security.cert.X509Certificate[] getPeerCertificates()

Specified by:

getPeerCertificates in interface MQTTTransport

getInactivityMonitor

public MQTTInactivityMonitor getInactivityMonitor()

Specified by:

getInactivityMonitor in interface MQTTTransport

getWireFormat

public MQTTWireFormat getWireFormat()

Specified by:

getWireFormat in interface MQTTTransport

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware