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 Description MQTTSslTransportFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Transport
compositeConfigure(Transport transport, WireFormat format, Map options)
Overriding to allow for proper configuration through reflection but delegate to get common configurationprotected 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, createTransport, doBind
-
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransportFactory
createTcpTransport, createTcpTransportServer, 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
-
-
-
-
Method Detail
-
getDefaultWireFormatType
protected String getDefaultWireFormatType()
- Overrides:
getDefaultWireFormatType
in classTransportFactory
-
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 classSslTransportFactory
- 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 classSslTransportFactory
- 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 classTransportFactory
- Returns:
- Throws:
Exception
-
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interfaceBrokerServiceAware
-
createInactivityMonitor
protected Transport createInactivityMonitor(Transport transport, WireFormat format)
- Overrides:
createInactivityMonitor
in classTcpTransportFactory
-
-