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
Methods inherited from class org.apache.activemq.transport.TransportFactory |
bind, bind, bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, getOption, registerTransportFactory |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MQTTSslTransportFactory
public MQTTSslTransportFactory()
getDefaultWireFormatType
protected java.lang.String getDefaultWireFormatType()
- Overrides:
getDefaultWireFormatType
in class TransportFactory
compositeConfigure
public Transport compositeConfigure(Transport transport,
WireFormat format,
java.util.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:
serverConfigure
public Transport serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
throws java.lang.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:
java.lang.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
Copyright © 2005-2015. All Rights Reserved.