Package org.apache.activemq.transport.mqtt

Class MQTTNIOTransportFactory

java.lang.Object
org.apache.activemq.transport.TransportFactory
org.apache.activemq.transport.tcp.TcpTransportFactory
org.apache.activemq.transport.nio.NIOTransportFactory
org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory
All Implemented Interfaces:
org.apache.activemq.broker.BrokerServiceAware
Direct Known Subclasses:
MQTTNIOSSLTransportFactory
public class MQTTNIOTransportFactory extends org.apache.activemq.transport.nio.NIOTransportFactory implements org.apache.activemq.broker.BrokerServiceAware
A MQTT over NIO transport factory

  • Constructor Summary

    Constructors
    Constructor
    Description
    MQTTNIOTransportFactory()
     

  • 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.TcpTransport
    createTcpTransport(org.apache.activemq.wireformat.WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation)
     
    protected org.apache.activemq.transport.tcp.TcpTransportServer
    createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory)
     
    org.apache.activemq.transport.tcp.TcpTransport
    createTransport(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket, org.apache.activemq.transport.tcp.TcpTransport.InitBuffer initBuffer)
     
    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.nio.NIOTransportFactory

    createServerSocketFactory, createSocketFactory

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

    createTransport, createTransport, doBind, 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

    • MQTTNIOTransportFactory

      public MQTTNIOTransportFactory()

  • Method Details

    • getDefaultWireFormatType

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

    • createTcpTransportServer

      protected org.apache.activemq.transport.tcp.TcpTransportServer createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
      Overrides:
      createTcpTransportServer in class org.apache.activemq.transport.nio.NIOTransportFactory
      Throws:
      IOException
      URISyntaxException

    • createTcpTransport

      protected org.apache.activemq.transport.tcp.TcpTransport createTcpTransport(org.apache.activemq.wireformat.WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation) throws UnknownHostException, IOException
      Overrides:
      createTcpTransport in class org.apache.activemq.transport.nio.NIOTransportFactory
      Throws:
      UnknownHostException
      IOException

    • createTransport

      public org.apache.activemq.transport.tcp.TcpTransport createTransport(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket, org.apache.activemq.transport.tcp.TcpTransport.InitBuffer initBuffer) throws IOException
      Overrides:
      createTransport in class org.apache.activemq.transport.nio.NIOTransportFactory
      Throws:
      IOException

    • 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

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

    • 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