Package org.wso2.carbon.inbound.endpoint.protocol.rabbitmq

Class RabbitMQConnectionFactory

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQConnectionFactory

public class RabbitMQConnectionFactory
extends Object

Encapsulate a RabbitMQ AMQP Connection factory definition within an inbound configuration

Constructor Summary

Constructors

Constructor	Description
RabbitMQConnectionFactory(Properties properties)	Digest a AMQP CF definition from the configuration and construct

Method Summary

Modifier and Type	Method	Description
com.rabbitmq.client.Connection	createConnection()	Create a RabbitMQ connection
String	getContent()
String	getName()	get connection factory name
Map<String,String>	getParameters()	Get all rabbit mq parameters
void	setName(String name)	Set connection factory name

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMQConnectionFactory

public RabbitMQConnectionFactory(Properties properties)
                          throws RabbitMQException

Digest a AMQP CF definition from the configuration and construct

Throws:

RabbitMQException

Method Details

getName

public String getName()

get connection factory name

Returns:

connection factory name

setName

public void setName(String name)

Set connection factory name

Parameters:

name - name to set for the connection Factory

getContent

public String getContent()

getParameters

public Map<String,String> getParameters()

Get all rabbit mq parameters

Returns:

a map of parameters

createConnection

public com.rabbitmq.client.Connection createConnection()
                                                throws RabbitMQException

Create a RabbitMQ connection

Returns:

a Connection object

Throws:

RabbitMQException