org.apache.synapse.transport.amqp.connectionfactory

Class AMQPTransportConnectionFactoryManager

java.lang.Object

org.apache.synapse.transport.amqp.connectionfactory.AMQPTransportConnectionFactoryManager

public class AMQPTransportConnectionFactoryManager
extends Object

Holds a list of AMQPTransportConnectionFactory.

Constructor Summary

Constructors

Constructor and Description
AMQPTransportConnectionFactoryManager()

Method Summary

Modifier and Type	Method and Description
void	addConnectionFactories(org.apache.axis2.description.ParameterInclude transportInDescription, ExecutorService es) Add the list of defined connection factories definition.
void	addConnectionFactory(org.apache.axis2.description.Parameter parameter, ExecutorService es) Add a connection factory definition into store.
void	addConnectionFactory(String name, AMQPTransportConnectionFactory cf)
ConcurrentHashMap<String,AMQPTransportConnectionFactory>	getAllFactories()
AMQPTransportConnectionFactory	getConnectionFactory(String name) Get the connection factory with this name.
void	removeConnectionFactory(String name) Remove and return the connection factory with this name.
void	shutDownConnectionFactories() Shutdown the open connections to the broker via the connection factory

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AMQPTransportConnectionFactoryManager

public AMQPTransportConnectionFactoryManager()

Method Detail

addConnectionFactories

public void addConnectionFactories(org.apache.axis2.description.ParameterInclude transportInDescription,
                                   ExecutorService es)

Add the list of defined connection factories definition.

Parameters:

transportInDescription - The connection factory definition in axis2.xml

es - An instance of java.util.concurrent.ExecutorService to use with AMQP connection factory

addConnectionFactory

public void addConnectionFactory(org.apache.axis2.description.Parameter parameter,
                                 ExecutorService es)
                          throws AMQPTransportException

Add a connection factory definition into store.

Throws:

AMQPTransportException

addConnectionFactory

public void addConnectionFactory(String name,
                                 AMQPTransportConnectionFactory cf)

getConnectionFactory

public AMQPTransportConnectionFactory getConnectionFactory(String name)
                                                    throws AMQPTransportException

Get the connection factory with this name.

Parameters:

name - connection factory name.

Returns:

the connection factory with this name.

Throws:

AMQPTransportException - throws in case of an error.

removeConnectionFactory

public void removeConnectionFactory(String name)
                             throws AMQPTransportException

Remove and return the connection factory with this name.

Parameters:

name - connection factory name.

Throws:

AMQPTransportException - throws in case of an error.

shutDownConnectionFactories

public void shutDownConnectionFactories()
                                 throws AMQPTransportException

Shutdown the open connections to the broker via the connection factory

Throws:

AMQPTransportException

getAllFactories

public ConcurrentHashMap<String,AMQPTransportConnectionFactory> getAllFactories()