public class RabbitMQConnectionFactory extends Object
Constructor and Description |
---|
RabbitMQConnectionFactory(Properties properties)
Digest a AMQP CF definition from the configuration and construct
|
RabbitMQConnectionFactory(String name,
Hashtable<String,String> parameters)
Create a connection factory based on given parameters
|
Modifier and Type | Method and Description |
---|---|
com.rabbitmq.client.Connection |
createConnection()
Create a rabbit mq connection
|
String |
getContent() |
String |
getName()
get connection factory name
|
Map<String,String> |
getParameters()
Get all rabbit mq parameters
|
int |
getRetryCount() |
int |
getRetryInterval() |
void |
initConnectionFactory()
Initialize connection factory
|
void |
setName(String name)
Set connection factory name
|
public RabbitMQConnectionFactory(Properties properties)
public String getName()
public void setName(String name)
name
- name to set for the connection Factorypublic String getContent()
public Map<String,String> getParameters()
public void initConnectionFactory()
public com.rabbitmq.client.Connection createConnection() throws IOException
IOException
public int getRetryInterval()
public int getRetryCount()
Copyright © 2018 WSO2. All rights reserved.