public class AmqpNioTransportFactory extends org.apache.activemq.transport.nio.NIOTransportFactory implements BrokerServiceAware
Constructor and Description |
---|
AmqpNioTransportFactory() |
Modifier and Type | Method and Description |
---|---|
Transport |
compositeConfigure(Transport transport,
org.apache.activemq.wireformat.WireFormat format,
Map options) |
protected Transport |
createInactivityMonitor(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) |
protected String |
getDefaultWireFormatType() |
Transport |
serverConfigure(Transport transport,
org.apache.activemq.wireformat.WireFormat format,
HashMap options) |
void |
setBrokerService(BrokerService brokerService) |
createServerSocketFactory, createSocketFactory
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 org.apache.activemq.transport.tcp.TcpTransportServer createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
createTcpTransportServer
in class org.apache.activemq.transport.nio.NIOTransportFactory
IOException
URISyntaxException
protected org.apache.activemq.transport.tcp.TcpTransport createTcpTransport(org.apache.activemq.wireformat.WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation) throws UnknownHostException, IOException
createTcpTransport
in class org.apache.activemq.transport.nio.NIOTransportFactory
UnknownHostException
IOException
public Transport serverConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, HashMap options) throws Exception
serverConfigure
in class TransportFactory
Exception
public Transport compositeConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, Map options)
compositeConfigure
in class org.apache.activemq.transport.tcp.TcpTransportFactory
protected Transport createInactivityMonitor(Transport transport, org.apache.activemq.wireformat.WireFormat format)
createInactivityMonitor
in class org.apache.activemq.transport.tcp.TcpTransportFactory
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.