public class AmqpNioTransportFactory extends NIOTransportFactory implements BrokerServiceAware
Constructor and Description |
---|
AmqpNioTransportFactory() |
Modifier and Type | Method and Description |
---|---|
Transport |
compositeConfigure(Transport transport,
WireFormat format,
Map options)
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.
|
protected Transport |
createInactivityMonitor(Transport transport,
WireFormat format) |
protected TcpTransport |
createTcpTransport(WireFormat wf,
SocketFactory socketFactory,
URI location,
URI localLocation)
Allows subclasses of TcpTransportFactory to provide a create custom
TcpTransport instances.
|
protected TcpTransportServer |
createTcpTransportServer(URI location,
ServerSocketFactory serverSocketFactory)
Allows subclasses of TcpTransportFactory to create custom instances of
TcpTransportServer.
|
TcpTransport |
createTransport(WireFormat wireFormat,
Socket socket,
TcpTransport.InitBuffer initBuffer) |
protected String |
getDefaultWireFormatType() |
Transport |
serverConfigure(Transport transport,
WireFormat format,
HashMap options)
Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker.
|
void |
setBrokerService(BrokerService brokerService) |
createServerSocketFactory, createSocketFactory
createTransport, createTransport, doBind, isUseInactivityMonitor
bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, findTransportFactory, getOption, registerTransportFactory
public AmqpNioTransportFactory()
protected String getDefaultWireFormatType()
getDefaultWireFormatType
in class TransportFactory
protected TcpTransportServer createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
TcpTransportFactory
createTcpTransportServer
in class NIOTransportFactory
IOException
URISyntaxException
protected TcpTransport createTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation) throws UnknownHostException, IOException
TcpTransportFactory
createTcpTransport
in class NIOTransportFactory
UnknownHostException
IOException
public TcpTransport createTransport(WireFormat wireFormat, Socket socket, TcpTransport.InitBuffer initBuffer) throws IOException
createTransport
in class NIOTransportFactory
IOException
public Transport serverConfigure(Transport transport, WireFormat format, HashMap options) throws Exception
TransportFactory
serverConfigure
in class TransportFactory
Exception
public Transport compositeConfigure(Transport transport, WireFormat format, Map options)
TransportFactory
compositeConfigure
in class TcpTransportFactory
protected Transport createInactivityMonitor(Transport transport, WireFormat format)
createInactivityMonitor
in class TcpTransportFactory
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.