public class RabbitMQUtils extends Object
Constructor and Description |
---|
RabbitMQUtils() |
Modifier and Type | Method and Description |
---|---|
static com.rabbitmq.client.Connection |
createConnection(com.rabbitmq.client.ConnectionFactory factory,
com.rabbitmq.client.Address[] addresses) |
static void |
declareExchange(com.rabbitmq.client.Connection connection,
String exchangeName,
Hashtable<String,String> properties) |
static void |
declareQueue(com.rabbitmq.client.Connection connection,
String queueName,
boolean isDurable,
boolean isExclusive,
boolean isAutoDelete) |
static void |
declareQueue(com.rabbitmq.client.Connection connection,
String queueName,
Hashtable<String,String> properties) |
static String |
getProperty(org.apache.axis2.context.MessageContext mc,
String key) |
static void |
handleException(String message,
Exception e) |
static boolean |
isAutoDeleteQueue(Hashtable<String,String> properties) |
static boolean |
isDurableQueue(Hashtable<String,String> properties) |
static boolean |
isExclusiveQueue(Hashtable<String,String> properties) |
static boolean |
isQueueAvailable(com.rabbitmq.client.Connection connection,
String queueName) |
public static com.rabbitmq.client.Connection createConnection(com.rabbitmq.client.ConnectionFactory factory, com.rabbitmq.client.Address[] addresses) throws IOException
IOException
public static String getProperty(org.apache.axis2.context.MessageContext mc, String key)
public static boolean isQueueAvailable(com.rabbitmq.client.Connection connection, String queueName) throws IOException
IOException
public static void declareQueue(com.rabbitmq.client.Connection connection, String queueName, boolean isDurable, boolean isExclusive, boolean isAutoDelete) throws IOException
connection
- queueName
- isDurable
- isExclusive
- isAutoDelete
- IOException
public static void declareQueue(com.rabbitmq.client.Connection connection, String queueName, Hashtable<String,String> properties) throws IOException
IOException
public static void declareExchange(com.rabbitmq.client.Connection connection, String exchangeName, Hashtable<String,String> properties) throws IOException
IOException
Copyright © 2019 WSO2. All rights reserved.