org.apache.activemq.transport.amqp
Class AmqpNioTransportFactory

java.lang.Object
  org.apache.activemq.transport.TransportFactory
      org.apache.activemq.transport.tcp.TcpTransportFactory
          org.apache.activemq.transport.nio.NIOTransportFactory
              org.apache.activemq.transport.amqp.AmqpNioTransportFactory

All Implemented Interfaces:

BrokerServiceAware

Direct Known Subclasses:

AmqpNioSslTransportFactory

public class AmqpNioTransportFactory
extends NIOTransportFactory
implements BrokerServiceAware

A AMQP over NIO transport factory

Constructor Summary

AmqpNioTransportFactory()

Method Summary

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 TcpTransport	createTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation) Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.
protected TcpTransportServer	createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory) Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.
protected String	getDefaultWireFormatType()
protected boolean	isUseInactivityMonitor(Transport transport) Returns true if the inactivity monitor should be used on the transport
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)

Methods inherited from class org.apache.activemq.transport.nio.NIOTransportFactory

createServerSocketFactory, createSocketFactory

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

createInactivityMonitor, createTransport, doBind

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 Detail

AmqpNioTransportFactory

public AmqpNioTransportFactory()

Method Detail

getDefaultWireFormatType

protected String getDefaultWireFormatType()

Overrides:

getDefaultWireFormatType in class TransportFactory

createTcpTransportServer

protected TcpTransportServer createTcpTransportServer(URI location,
                                                      ServerSocketFactory serverSocketFactory)
                                               throws IOException,
                                                      URISyntaxException

Description copied from class: TcpTransportFactory

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.

Overrides:

createTcpTransportServer in class NIOTransportFactory

Returns:

Throws:

IOException

URISyntaxException

createTcpTransport

protected TcpTransport createTcpTransport(WireFormat wf,
                                          SocketFactory socketFactory,
                                          URI location,
                                          URI localLocation)
                                   throws UnknownHostException,
                                          IOException

Description copied from class: TcpTransportFactory

Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.

Overrides:

createTcpTransport in class NIOTransportFactory

Returns:

Throws:

UnknownHostException

IOException

serverConfigure

public Transport serverConfigure(Transport transport,
                                 WireFormat format,
                                 HashMap options)
                          throws 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:

Exception

compositeConfigure

public Transport compositeConfigure(Transport transport,
                                    WireFormat format,
                                    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

isUseInactivityMonitor

protected boolean isUseInactivityMonitor(Transport transport)

Description copied from class: TcpTransportFactory

Returns true if the inactivity monitor should be used on the transport

Overrides:

isUseInactivityMonitor in class TcpTransportFactory