com.si.celery

Class Celery

java.lang.Object

com.si.celery.Celery

All Implemented Interfaces:

java.lang.AutoCloseable

public class Celery
extends java.lang.Object
implements java.lang.AutoCloseable

The celery client for submitting and receiving tasks

Constructor Summary

Constructors

Constructor and Description
Celery()

Method Summary

Modifier and Type	Method and Description
void	close() Closes the program and performs cleanup.
void	registerTask(java.lang.Object task) Register a task object
void	registeTask(java.lang.String task) Add a task by string
java.util.concurrent.Future<AsyncResult>	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs) Send a task and await the result by name.
java.util.concurrent.Future<AsyncResult>	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, java.lang.Long softTimeLimit, long hardTimeLimit) Send a task and await the result by name.
java.util.concurrent.Future<AsyncResult>	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, java.lang.String correlationId, int priority, Task[] children, Options options) Send a task
java.util.concurrent.Future<AsyncResult>	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, Task[] children) Send a task and await the result by name.
void	submit() Submit a task using the class

Methods inherited from class java.lang.Object

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

Constructor Detail

Celery

public Celery()

Method Detail

submit

public void submit()

Submit a task using the class

sendTask

public java.util.concurrent.Future<AsyncResult> sendTask(java.lang.String taskName,
                                                         java.lang.Object[] args,
                                                         java.util.Map<java.lang.String,java.lang.Object> kwargs,
                                                         java.lang.String correlationId,
                                                         int priority,
                                                         Task[] children,
                                                         Options options)
                                                  throws BrokerSendTaskException,
                                                         java.security.NoSuchAlgorithmException,
                                                         java.security.KeyManagementException,
                                                         java.net.URISyntaxException,
                                                         java.lang.CloneNotSupportedException

Send a task

Parameters:

taskName - The task name

args - arguments

kwargs - mapped arguments

correlationId - correlation id

priority - priority

children - any child tasks

options - Options for the task

Returns:

Throws:

BrokerSendTaskException - Thrown if send fails

java.security.NoSuchAlgorithmException - Thrown by get

java.security.KeyManagementException - Thrown by get

java.net.URISyntaxException - Thrown by sendtask

java.lang.CloneNotSupportedException - Thrown when cloning config

sendTask

public java.util.concurrent.Future<AsyncResult> sendTask(java.lang.String taskName,
                                                         java.lang.Object[] args,
                                                         java.util.Map<java.lang.String,java.lang.Object> kwargs,
                                                         Task[] children)
                                                  throws java.lang.CloneNotSupportedException

Send a task and await the result by name.

Parameters:

taskName - The task name

args - The arguments

kwargs - The mapped arguments

children - children array

Returns:

future producing an async result

Throws:

java.lang.CloneNotSupportedException - Thrown when cloning config

sendTask

public java.util.concurrent.Future<AsyncResult> sendTask(java.lang.String taskName,
                                                         java.lang.Object[] args,
                                                         java.util.Map<java.lang.String,java.lang.Object> kwargs)
                                                  throws java.lang.CloneNotSupportedException

Send a task and await the result by name.

Parameters:

taskName - The task name

args - The arguments

kwargs - The mapped arguments

Returns:

future producing an async result

Throws:

java.lang.CloneNotSupportedException - Thrown when cloning config

sendTask

public java.util.concurrent.Future<AsyncResult> sendTask(java.lang.String taskName,
                                                         java.lang.Object[] args,
                                                         java.util.Map<java.lang.String,java.lang.Object> kwargs,
                                                         java.lang.Long softTimeLimit,
                                                         long hardTimeLimit)
                                                  throws java.lang.CloneNotSupportedException

Send a task and await the result by name.

Parameters:

taskName - The task name

args - The arguments

kwargs - The mapped arguments

softTimeLimit - soft time limit

hardTimeLimit - The hard time limit

Returns:

future producing an async result

Throws:

java.lang.CloneNotSupportedException - Thrown when cloning config

registerTask

public void registerTask(java.lang.Object task)

Register a task object

Parameters:

task - The task to register

registeTask

public void registeTask(java.lang.String task)

Add a task by string

Parameters:

task - The task name string

close

public void close()

Closes the program and performs cleanup. Will terminate running threads with shutdownNow.

Specified by:

close in interface java.lang.AutoCloseable