Class NIOTransportFactory
- java.lang.Object
-
- org.apache.activemq.transport.TransportFactory
-
- org.apache.activemq.transport.tcp.TcpTransportFactory
-
- org.apache.activemq.transport.nio.NIOTransportFactory
-
- Direct Known Subclasses:
AmqpNioTransportFactory,AutoNioTransportFactory,MQTTNIOTransportFactory,NIOSSLTransportFactory,StompNIOTransportFactory
public class NIOTransportFactory extends TcpTransportFactory
-
-
Constructor Summary
Constructors Constructor Description NIOTransportFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ServerSocketFactorycreateServerSocketFactory()protected SocketFactorycreateSocketFactory()protected TcpTransportcreateTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation)Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport instances.protected TcpTransportServercreateTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory)Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.TcpTransportcreateTransport(WireFormat wireFormat, Socket socket, TcpTransport.InitBuffer initBuffer)-
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransportFactory
compositeConfigure, createInactivityMonitor, 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, getDefaultWireFormatType, getOption, registerTransportFactory, serverConfigure
-
-
-
-
Method Detail
-
createTcpTransportServer
protected TcpTransportServer createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
Description copied from class:TcpTransportFactoryAllows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.- Overrides:
createTcpTransportServerin classTcpTransportFactory- Returns:
- a new TcpTransportServer instance.
- Throws:
IOExceptionURISyntaxException
-
createTcpTransport
protected TcpTransport createTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation) throws UnknownHostException, IOException
Description copied from class:TcpTransportFactoryAllows subclasses of TcpTransportFactory to provide a create custom TcpTransport instances.- Overrides:
createTcpTransportin classTcpTransportFactory- Returns:
- a new TcpTransport instance connected to the given location.
- Throws:
UnknownHostExceptionIOException
-
createTransport
public TcpTransport createTransport(WireFormat wireFormat, Socket socket, TcpTransport.InitBuffer initBuffer) throws IOException
- Overrides:
createTransportin classTcpTransportFactory- Throws:
IOException
-
createServerSocketFactory
protected ServerSocketFactory createServerSocketFactory()
- Overrides:
createServerSocketFactoryin classTcpTransportFactory
-
createSocketFactory
protected SocketFactory createSocketFactory() throws IOException
- Overrides:
createSocketFactoryin classTcpTransportFactory- Throws:
IOException
-
-