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 Map |
getTransportHeaders(RabbitMQMessage message) |
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 Map getTransportHeaders(RabbitMQMessage message)
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 © 2020 WSO2. All rights reserved.