org.apache.activemq.transport.amqp
Class AmqpTransportFactory

java.lang.Object
  extended by org.apache.activemq.transport.TransportFactory
      extended by org.apache.activemq.transport.tcp.TcpTransportFactory
          extended by org.apache.activemq.transport.amqp.AmqpTransportFactory
All Implemented Interfaces:
BrokerServiceAware

public class AmqpTransportFactory
extends TcpTransportFactory
implements BrokerServiceAware

A AMQP transport factory


Constructor Summary
AmqpTransportFactory()
           
 
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  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.tcp.TcpTransportFactory
createInactivityMonitor, createServerSocketFactory, createSocketFactory, createTcpTransport, createTcpTransportServer, 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

AmqpTransportFactory

public AmqpTransportFactory()
Method Detail

getDefaultWireFormatType

protected String getDefaultWireFormatType()
Overrides:
getDefaultWireFormatType in class TransportFactory

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

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

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


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.