Package org.apache.activemq.transport.amqp

Class AmqpTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

org.apache.activemq.transport.amqp.AmqpTransportFactory

All Implemented Interfaces:

BrokerServiceAware

public class AmqpTransportFactory
extends org.apache.activemq.transport.tcp.TcpTransportFactory
implements BrokerServiceAware

A AMQP transport factory

Constructor Summary

Constructors

Constructor	Description
AmqpTransportFactory()

Method Summary

Modifier and Type	Method	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 String	getDefaultWireFormatType()
Transport	serverConfigure(Transport transport, org.apache.activemq.wireformat.WireFormat format, HashMap options)
void	setBrokerService(BrokerService brokerService)

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

createServerSocketFactory, createSocketFactory, createTcpTransport, createTcpTransportServer, createTransport, 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, 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,
                                    org.apache.activemq.wireformat.WireFormat format,
                                    Map options)

Overrides:

compositeConfigure in class org.apache.activemq.transport.tcp.TcpTransportFactory

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware

serverConfigure

public Transport serverConfigure(Transport transport,
                                 org.apache.activemq.wireformat.WireFormat format,
                                 HashMap options)
                          throws Exception

Overrides:

serverConfigure in class TransportFactory

Throws:

Exception

createInactivityMonitor

protected Transport createInactivityMonitor(Transport transport,
                                            org.apache.activemq.wireformat.WireFormat format)

Overrides:

createInactivityMonitor in class org.apache.activemq.transport.tcp.TcpTransportFactory