com.si.celery.queue

Class ClientQueueUtils

java.lang.Object

com.si.celery.queue.ClientQueueUtils

public class ClientQueueUtils
extends java.lang.Object

Client Queue helper library. Channel and connetion must be externally managed.

Constructor Summary

Constructors

Constructor and Description
ClientQueueUtils(com.rabbitmq.client.Connection connection, com.rabbitmq.client.Channel channel) Constructor with connection and channel
ClientQueueUtils(ConnectionInf connInf)

Method Summary

Modifier and Type	Method and Description
void	bindToQueue(java.lang.String queueName, java.lang.String exchangeName, java.lang.String routingKey) Bind to the specified queue
boolean	createResultQueue(java.lang.String uuid, boolean durable) Create a queue
boolean	createRoutingQueue(java.lang.String queue, boolean durable) Create the routing queue
void	declareExchange(java.lang.String exchange, java.lang.String exchangeType) Declare an exchange and exchange type.
boolean	destroy(java.lang.String uuid) Attempt to destroy the queue

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientQueueUtils

public ClientQueueUtils(ConnectionInf connInf)

ClientQueueUtils

public ClientQueueUtils(com.rabbitmq.client.Connection connection,
                        com.rabbitmq.client.Channel channel)

Constructor with connection and channel

Parameters:

connection - The connection for AMQP

channel - The channel for AMQP

Method Detail

declareExchange

public void declareExchange(java.lang.String exchange,
                            java.lang.String exchangeType)
                     throws java.io.IOException

Declare an exchange and exchange type.

Parameters:

exchange - The exchange name

exchangeType - The exchange type

Throws:

java.io.IOException - Exception thrown if queue cannot be declared

bindToQueue

public void bindToQueue(java.lang.String queueName,
                        java.lang.String exchangeName,
                        java.lang.String routingKey)
                 throws java.io.IOException

Bind to the specified queue

Parameters:

queueName - Name of the queue

exchangeName - Name of the exchange

routingKey - Routing key for the bind

Throws:

java.io.IOException

createResultQueue

public boolean createResultQueue(java.lang.String uuid,
                                 boolean durable)

Create a queue

Parameters:

uuid - The uuid queue name

durable - Whether the queue should persist

Returns:

Whether the operation may have been sucessful

createRoutingQueue

public boolean createRoutingQueue(java.lang.String queue,
                                  boolean durable)

Create the routing queue

Parameters:

queue - The queue to route with

durable - Whether the queue should persist

Returns:

Whether the operation may have been succesful

destroy

public boolean destroy(java.lang.String uuid)

Attempt to destroy the queue

Parameters:

uuid - The queue uuid name

Returns:

Whether the queue may have been deleted