Package org.apache.activemq.transport.mqtt

Class MQTTNIOTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

org.apache.activemq.transport.nio.NIOTransportFactory

org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

All Implemented Interfaces:

BrokerServiceAware

Direct Known Subclasses:

MQTTNIOSSLTransportFactory

public class MQTTNIOTransportFactory
extends NIOTransportFactory
implements BrokerServiceAware

A MQTT over NIO transport factory

Constructor Summary

Constructors

Constructor	Description
MQTTNIOTransportFactory()

Method Summary

Modifier and Type	Method	Description
Transport	compositeConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, Map options)
protected Transport	createInactivityMonitor(Transport transport, org.apache.activemq.wireformat.WireFormat format)
protected org.apache.activemq.transport.tcp.TcpTransport	createTcpTransport(org.apache.activemq.wireformat.WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation)
protected org.apache.activemq.transport.tcp.TcpTransportServer	createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory)
org.apache.activemq.transport.tcp.TcpTransport	createTransport(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket, org.apache.activemq.transport.tcp.TcpTransport.InitBuffer initBuffer)
protected String	getDefaultWireFormatType()
Transport	serverConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, HashMap options)
void	setBrokerService(BrokerService brokerService)

Methods inherited from class org.apache.activemq.transport.nio.NIOTransportFactory

createServerSocketFactory, createSocketFactory

Methods inherited from class org.apache.activemq.transport.tcp.TcpTransportFactory

createTransport, createTransport, doBind, isUseInactivityMonitor

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

bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, findTransportFactory, getOption, registerTransportFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

MQTTNIOTransportFactory

public MQTTNIOTransportFactory()

Method Detail

getDefaultWireFormatType

protected String getDefaultWireFormatType()

Overrides:

getDefaultWireFormatType in class TransportFactory

createTcpTransportServer

protected org.apache.activemq.transport.tcp.TcpTransportServer createTcpTransportServer(URI location,
                                                                                        ServerSocketFactory serverSocketFactory)
                                                                                 throws IOException,
                                                                                        URISyntaxException

Overrides:

createTcpTransportServer in class NIOTransportFactory

Throws:

IOException

URISyntaxException

createTcpTransport

protected org.apache.activemq.transport.tcp.TcpTransport createTcpTransport(org.apache.activemq.wireformat.WireFormat wf,
                                                                            SocketFactory socketFactory,
                                                                            URI location,
                                                                            URI localLocation)
                                                                     throws UnknownHostException,
                                                                            IOException

Overrides:

createTcpTransport in class NIOTransportFactory

Throws:

UnknownHostException

IOException

createTransport

public org.apache.activemq.transport.tcp.TcpTransport createTransport(org.apache.activemq.wireformat.WireFormat wireFormat,
                                                                      Socket socket,
                                                                      org.apache.activemq.transport.tcp.TcpTransport.InitBuffer initBuffer)
                                                               throws IOException

Overrides:

createTransport in class NIOTransportFactory

Throws:

IOException

serverConfigure

public Transport serverConfigure(Transport transport,
                                 org.apache.activemq.wireformat.WireFormat format,
                                 HashMap options)
                          throws Exception

Overrides:

serverConfigure in class TransportFactory

Throws:

Exception

compositeConfigure

public Transport compositeConfigure(Transport transport,
                                    org.apache.activemq.wireformat.WireFormat format,
                                    Map options)

Overrides:

compositeConfigure in class org.apache.activemq.transport.tcp.TcpTransportFactory

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware

createInactivityMonitor

protected Transport createInactivityMonitor(Transport transport,
                                            org.apache.activemq.wireformat.WireFormat format)

Overrides:

createInactivityMonitor in class org.apache.activemq.transport.tcp.TcpTransportFactory