org.apache.activemq.transport.mqtt

Class MQTTSslTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

org.apache.activemq.transport.tcp.SslTransportFactory

org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

All Implemented Interfaces:

BrokerServiceAware

public class MQTTSslTransportFactory
extends SslTransportFactory
implements BrokerServiceAware

A MQTT over SSL transport factory

Constructor Summary

Constructors

Constructor and Description
MQTTSslTransportFactory()

Method Summary

Modifier and Type	Method and Description
Transport	compositeConfigure(Transport transport, WireFormat format, Map options) Overriding to allow for proper configuration through reflection but delegate to get common configuration
protected Transport	createInactivityMonitor(Transport transport, WireFormat format)
protected SslTransportServer	createSslTransportServer(URI location, SSLServerSocketFactory serverSocketFactory) Allows subclasses of SslTransportFactory to create custom instances of SslTransportServer.
protected String	getDefaultWireFormatType()
Transport	serverConfigure(Transport transport, WireFormat format, HashMap options) Fully configures and adds all need transport filters so that the transport can be used by the ActiveMQ message broker.
void	setBrokerService(BrokerService brokerService)

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

createServerSocketFactory, createSocketFactory, createTransport, doBind

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

createTcpTransport, createTcpTransportServer, createTransport, createTransport, 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

MQTTSslTransportFactory

public MQTTSslTransportFactory()

Method Detail

getDefaultWireFormatType

protected String getDefaultWireFormatType()

Overrides:

getDefaultWireFormatType in class TransportFactory

compositeConfigure

public Transport compositeConfigure(Transport transport,
                                    WireFormat format,
                                    Map options)

Description copied from class: SslTransportFactory

Overriding to allow for proper configuration through reflection but delegate to get common configuration

Overrides:

compositeConfigure in class SslTransportFactory

Returns:

createSslTransportServer

protected SslTransportServer createSslTransportServer(URI location,
                                                      SSLServerSocketFactory serverSocketFactory)
                                               throws IOException,
                                                      URISyntaxException

Description copied from class: SslTransportFactory

Allows subclasses of SslTransportFactory to create custom instances of SslTransportServer.

Overrides:

createSslTransportServer in class SslTransportFactory

Returns:

a new SslTransportServer initialized from the given location and socket factory.

Throws:

IOException

URISyntaxException

serverConfigure

public Transport serverConfigure(Transport transport,
                                 WireFormat format,
                                 HashMap options)
                          throws Exception

Description copied from class: TransportFactory

Fully configures and adds all need transport filters so that the transport can be used by the ActiveMQ message broker. The main difference between this and the configure() method is that the broker does not issue requests to the client so the ResponseCorrelator is not needed.

Overrides:

serverConfigure in class TransportFactory

Returns:

Throws:

Exception

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware

createInactivityMonitor

protected Transport createInactivityMonitor(Transport transport,
                                            WireFormat format)

Overrides:

createInactivityMonitor in class TcpTransportFactory