public class MQTTSslTransportFactory extends org.apache.activemq.transport.tcp.SslTransportFactory implements BrokerServiceAware
Constructor and Description |
---|
MQTTSslTransportFactory() |
Modifier and Type | Method and 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.SslTransportServer |
createSslTransportServer(URI location,
SSLServerSocketFactory serverSocketFactory) |
protected String |
getDefaultWireFormatType() |
Transport |
serverConfigure(Transport transport,
org.apache.activemq.wireformat.WireFormat format,
HashMap options) |
void |
setBrokerService(BrokerService brokerService) |
createServerSocketFactory, createSocketFactory, createTransport, doBind
createTcpTransport, createTcpTransportServer, isUseInactivityMonitor
bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, findTransportFactory, getOption, registerTransportFactory
public MQTTSslTransportFactory()
protected String getDefaultWireFormatType()
getDefaultWireFormatType
in class TransportFactory
public Transport compositeConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, Map options)
compositeConfigure
in class org.apache.activemq.transport.tcp.SslTransportFactory
protected org.apache.activemq.transport.tcp.SslTransportServer createSslTransportServer(URI location, SSLServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
createSslTransportServer
in class org.apache.activemq.transport.tcp.SslTransportFactory
IOException
URISyntaxException
public Transport serverConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, HashMap options) throws Exception
serverConfigure
in class TransportFactory
Exception
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
protected Transport createInactivityMonitor(Transport transport, org.apache.activemq.wireformat.WireFormat format)
createInactivityMonitor
in class org.apache.activemq.transport.tcp.TcpTransportFactory
Copyright © 2005–2022 FuseSource, Corp.. All rights reserved.