Package org.apache.activemq.transport.mqtt

Class MQTTTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

org.apache.activemq.transport.mqtt.MQTTTransportFactory

All Implemented Interfaces:

org.apache.activemq.broker.BrokerServiceAware

public class MQTTTransportFactory
extends org.apache.activemq.transport.tcp.TcpTransportFactory
implements org.apache.activemq.broker.BrokerServiceAware

A MQTT transport factory

Constructor Summary

Constructors

Constructor	Description
MQTTTransportFactory()

Method Summary

Modifier and Type	Method	Description
org.apache.activemq.transport.Transport	compositeConfigure(org.apache.activemq.transport.Transport transport, org.apache.activemq.wireformat.WireFormat format, Map options)
protected org.apache.activemq.transport.Transport	createInactivityMonitor(org.apache.activemq.transport.Transport transport, org.apache.activemq.wireformat.WireFormat format)
protected org.apache.activemq.transport.tcp.TcpTransportServer	createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory)
protected String	getDefaultWireFormatType()
org.apache.activemq.transport.Transport	serverConfigure(org.apache.activemq.transport.Transport transport, org.apache.activemq.wireformat.WireFormat format, HashMap options)
void	setBrokerService(org.apache.activemq.broker.BrokerService brokerService)

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

createServerSocketFactory, createSocketFactory, createTcpTransport, createTransport, 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 Details

MQTTTransportFactory

public MQTTTransportFactory()

Method Details

getDefaultWireFormatType

protected String getDefaultWireFormatType()

Overrides:

getDefaultWireFormatType in class org.apache.activemq.transport.TransportFactory

createTcpTransportServer

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

Overrides:

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

Throws:

IOException

URISyntaxException

compositeConfigure

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

Overrides:

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

setBrokerService

public void setBrokerService(org.apache.activemq.broker.BrokerService brokerService)

Specified by:

setBrokerService in interface org.apache.activemq.broker.BrokerServiceAware

serverConfigure

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

Overrides:

serverConfigure in class org.apache.activemq.transport.TransportFactory

Throws:

Exception

createInactivityMonitor

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

Overrides:

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