org.apache.synapse.transport.amqp.connectionfactory

Class AMQPTransportConnectionFactory

java.lang.Object

org.apache.synapse.transport.amqp.connectionfactory.AMQPTransportConnectionFactory

public class AMQPTransportConnectionFactory
extends Object

This wrap the connection factory definition in axis2.xml. See below for an example definition.

 
 <transportReceiver name="amqp" class="org.wso2.carbon.transports.amqp.AMQPTransportListener">
 <parameter name="example-connection-factory1" locked="false">
      <parameter name="transport.amqp.Uri" locked="false">amqp://userName:password@hostName:portNumber/virtualHost</parameter>
      <parameter name="transport.amqp.BrokerList" locked="false">hostName1:portNumber1,hostName2:portNumber2,hostName3:portNumber3</parameter>
 </parameter>

 <parameter name="example-connection-factory2" locked="false">
     <parameter name="example-connection-factory1" locked="false">
     <parameter name="transport.amqp.Uri" locked="false">amqp://userName:password@hostName:portNumber/virtualHost</parameter>
     <parameter name="transport.amqp.BrokerList" locked="false">hostName1:portNumber1,hostName2:portNumber2,hostName3:portNumber3</parameter>
 </parameter>

 <parameter name="default" locked="false">
     <parameter name="example-connection-factory1" locked="false">
     <parameter name="transport.amqp.Uri" locked="false">amqp://userName:password@hostName:portNumber/virtualHost</parameter>
     <parameter name="transport.amqp.BrokerList" locked="false">hostName1:portNumber1,hostName2:portNumber2,hostName3:portNumber3</parameter>
 </parameter>
 </transportReceiver>
 
 

Constructor Summary

Constructors

Constructor and Description
AMQPTransportConnectionFactory(Map<String,String> parameters, ExecutorService es)
AMQPTransportConnectionFactory(org.apache.axis2.description.Parameter parameter, ExecutorService es)

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Channel	getChannel() Get the channel in this connection.
com.rabbitmq.client.Connection	getConnection() Get the connection
String	getName() Return the name of this connection factory(the name given in axis2.xml)
Map<String,String>	getParameters() Returns the list of all parameters in this connection factory.
String	getParameterValue(String parameterName) Returns the value of parameter.
void	shutDownChannel() Shutdown this channel.
void	shutDownConnection() Shutdown this connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportConnectionFactory

public AMQPTransportConnectionFactory(Map<String,String> parameters,
                                      ExecutorService es)
                               throws AMQPTransportException

Throws:

AMQPTransportException

AMQPTransportConnectionFactory

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

Throws:

AMQPTransportException

Method Detail

shutDownConnection

public void shutDownConnection()
                        throws IOException

Shutdown this connection.

Throws:

IOException

shutDownChannel

public void shutDownChannel()
                     throws IOException

Shutdown this channel.

Throws:

IOException

getChannel

public com.rabbitmq.client.Channel getChannel()

Get the channel in this connection.

Returns:

channel associated with this

getConnection

public com.rabbitmq.client.Connection getConnection()

Get the connection

Returns:

the connection to broker.

getName

public String getName()

Return the name of this connection factory(the name given in axis2.xml)

Returns:

name of this connection factory

getParameterValue

public String getParameterValue(String parameterName)

Returns the value of parameter.

Parameters:

parameterName - name of the parameter.

Returns:

the value of the parameter.

getParameters

public Map<String,String> getParameters()

Returns the list of all parameters in this connection factory.

Returns:

the list of parameters.