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:
- BrokerServiceAware
- Direct Known Subclasses:
- MQTTNIOSSLTransportFactory
public class MQTTNIOTransportFactory
- extends NIOTransportFactory
- implements BrokerServiceAware
A MQTT over NIO 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 |
MQTTNIOTransportFactory
public MQTTNIOTransportFactory()
getDefaultWireFormatType
protected java.lang.String getDefaultWireFormatType()
- Overrides:
getDefaultWireFormatType
in class TransportFactory
createTcpTransportServer
protected TcpTransportServer createTcpTransportServer(java.net.URI location,
javax.net.ServerSocketFactory serverSocketFactory)
throws java.io.IOException,
java.net.URISyntaxException
- Description copied from class:
TcpTransportFactory
- Allows subclasses of TcpTransportFactory to create custom instances of
TcpTransportServer.
- Overrides:
createTcpTransportServer
in class NIOTransportFactory
- Returns:
-
- Throws:
java.io.IOException
java.net.URISyntaxException
createTcpTransport
protected TcpTransport createTcpTransport(WireFormat wf,
javax.net.SocketFactory socketFactory,
java.net.URI location,
java.net.URI localLocation)
throws java.net.UnknownHostException,
java.io.IOException
- Description copied from class:
TcpTransportFactory
- Allows subclasses of TcpTransportFactory to provide a create custom
TcpTransport intances.
- Overrides:
createTcpTransport
in class NIOTransportFactory
- Returns:
-
- Throws:
java.net.UnknownHostException
java.io.IOException
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
compositeConfigure
public Transport compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
- Description copied from class:
TransportFactory
- Similar to configure(...) but this avoid adding in the MutexTransport and
ResponseCorrelator transport layers so that the resulting transport can
more efficiently be used as part of a composite transport.
- Overrides:
compositeConfigure
in class TcpTransportFactory
- Returns:
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.