Package 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:
org.apache.activemq.broker.BrokerServiceAware
public class MQTTSslTransportFactory extends org.apache.activemq.transport.tcp.SslTransportFactory implements org.apache.activemq.broker.BrokerServiceAware
A MQTT over SSL transport factory

  • Constructor Summary

    Constructors
    Constructor
    Description
    MQTTSslTransportFactory()
     

  • 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.SslTransportServer
    createSslTransportServer(URI location, SSLServerSocketFactory 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.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

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MQTTSslTransportFactory

      public MQTTSslTransportFactory()

  • Method Details

    • getDefaultWireFormatType

      protected String getDefaultWireFormatType()
      Overrides:
      getDefaultWireFormatType in class org.apache.activemq.transport.TransportFactory

    • 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.SslTransportFactory

    • createSslTransportServer

      protected org.apache.activemq.transport.tcp.SslTransportServer createSslTransportServer(URI location, SSLServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
      Overrides:
      createSslTransportServer in class org.apache.activemq.transport.tcp.SslTransportFactory
      Throws:
      IOException
      URISyntaxException

    • 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

    • setBrokerService

      public void setBrokerService(org.apache.activemq.broker.BrokerService brokerService)
      Specified by:
      setBrokerService in interface org.apache.activemq.broker.BrokerServiceAware

    • 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