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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.rabbitmq.client.Connection
createConnection()
Create a RabbitMQ connectionString
getContent()
String
getName()
get connection factory nameMap<String,String>
getParameters()
Get all rabbit mq parametersvoid
setName(String name)
Set connection factory name
-
-
-
Constructor Detail
-
RabbitMQConnectionFactory
public RabbitMQConnectionFactory(Properties properties) throws RabbitMQException
Digest a AMQP CF definition from the configuration and construct- Throws:
RabbitMQException
-
-
Method Detail
-
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
-
-