com.si.celery.broker

Class RabbitMQBroker

java.lang.Object

com.si.celery.broker.RabbitMQBroker

All Implemented Interfaces:

Broker, java.lang.AutoCloseable

public class RabbitMQBroker
extends java.lang.Object
implements java.lang.AutoCloseable, Broker

Rabbit MQ Broker

Constructor Summary

Constructors

Constructor and Description
RabbitMQBroker(ConnectionInf connInf, Config config) Constructor taking prebuilt connection information
RabbitMQBroker(java.lang.String brokerURI, Config config) Constructor to use in coordination with connect

Method Summary

Modifier and Type	Method and Description
void	close() Close connections and other objects.
void	connect() Connect to the broker
SubtaskRunner	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs) Send a task with bare minimum requirements
SubtaskRunner	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, java.lang.Long softTimeLimit, java.lang.Long hardTimeLimit, int priority) Send a task with bare minimum requirements
SubtaskRunner	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, java.lang.String replyTo, java.lang.String correlationId, java.util.Date expires, int priority, java.lang.Long timeLimit, java.lang.Long softTimeLimit, java.util.Date eta, int retries) Send a task.
void	setOrigin(java.lang.String origin) Set the origin
void	setQueueName(java.lang.String queueName) Allows the push queue to be set
void	throwBrokerSendTaskException(java.lang.Exception e) Throws a send task exception

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMQBroker

public RabbitMQBroker(java.lang.String brokerURI,
                      Config config)

Constructor to use in coordination with connect

Parameters:

config - The RabbitMQ configuration

RabbitMQBroker

public RabbitMQBroker(ConnectionInf connInf,
                      Config config)

Constructor taking prebuilt connection information

Parameters:

connInf - The connection information

config - Configuration

Method Detail

setQueueName

public void setQueueName(java.lang.String queueName)

Allows the push queue to be set

Parameters:

queueName - The queue name

setOrigin

public void setOrigin(java.lang.String origin)

Set the origin

Specified by:

setOrigin in interface Broker

Parameters:

origin - The origin name

connect

public void connect()
             throws BrokerConnectionException

Connect to the broker

Specified by:

connect in interface Broker

Throws:

BrokerConnectionException

throwBrokerSendTaskException

public void throwBrokerSendTaskException(java.lang.Exception e)
                                  throws BrokerSendTaskException

Throws a send task exception

Parameters:

e - The exception

Throws:

BrokerSendTaskException

sendTask

public SubtaskRunner sendTask(java.lang.String taskName,
                              java.lang.Object[] args,
                              java.util.Map<java.lang.String,java.lang.Object> kwargs,
                              java.lang.String replyTo,
                              java.lang.String correlationId,
                              java.util.Date expires,
                              int priority,
                              java.lang.Long timeLimit,
                              java.lang.Long softTimeLimit,
                              java.util.Date eta,
                              int retries)
                       throws BrokerSendTaskException

Send a task.

Specified by:

sendTask in interface Broker

Parameters:

taskName - The task name

args - The arguments

kwargs - The mapped arguments

replyTo - The queue to reply to

correlationId - The correlation id

expires - The expiration date

priority - The priority for the message

timeLimit - The hard time limit for execution

softTimeLimit - The soft time limit for execution

eta - Estimated time of arrival

retries - Number of retries

Returns:

The subtask that can be awaited on with get

Throws:

BrokerSendTaskException - Thrown on failure to send a task

sendTask

public SubtaskRunner sendTask(java.lang.String taskName,
                              java.lang.Object[] args,
                              java.util.Map<java.lang.String,java.lang.Object> kwargs,
                              java.lang.Long softTimeLimit,
                              java.lang.Long hardTimeLimit,
                              int priority)
                       throws BrokerSendTaskException

Send a task with bare minimum requirements

Parameters:

taskName - The task name

args - The task arguments

kwargs - Mapped task arguments

softTimeLimit - The soft time limit

hardTimeLimit - The hard time limit

priority - The priority for the task

Returns:

Asynchronous result to wait for

Throws:

BrokerSendTaskException

sendTask

public SubtaskRunner sendTask(java.lang.String taskName,
                              java.lang.Object[] args,
                              java.util.Map<java.lang.String,java.lang.Object> kwargs)
                       throws BrokerSendTaskException

Send a task with bare minimum requirements

Specified by:

sendTask in interface Broker

Parameters:

taskName - The task name

args - The task arguments

kwargs - Mapped task arguments

Returns:

Asynchronous result to wait for

Throws:

BrokerSendTaskException

close

public void close()

Close connections and other objects. Allows for try-with-resources

Specified by:

close in interface java.lang.AutoCloseable