com.si.celery.task

Class Task

java.lang.Object

com.si.celery.task.Task

public class Task
extends java.lang.Object

Interface for a task

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	taskName

Constructor Summary

Constructors

Constructor and Description
Task(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs)
Task(java.lang.String taskName, Task[] children, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs)
Task(java.lang.String taskName, Task[] children, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, java.lang.String backendURI, ConnectionInf connInf, Config config, BackendType backendType, java.util.concurrent.ExecutorService executor, java.lang.String correlationId, TaskMessageV2 message, Options options, int priority)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Future<AsyncResult>	applyAsync() Calls delay for best practices
java.util.concurrent.Future<AsyncResult>	applyAsync(java.lang.Long softTimeLimit, java.lang.Long hardTimeLimit, java.lang.Long delay) Apply a task asynchronously with some common options to be set
java.util.concurrent.Future<AsyncResult>	applyAsync(java.lang.String queueName, java.lang.Long softTimeLimit, java.lang.Long hardTimeLimit, java.lang.Long delay) Apply a task asynchronously with some common options to be set
java.util.concurrent.Future<AsyncResult>	delay() Delay configured with defaults
java.util.concurrent.Future<AsyncResult>	delay(java.lang.Long delay) Run the task on a specified delay
void	executeChildren() Execute the children
AsyncResult	get() Bullds and calls get.
void	setConfig(Config config) Set the task configuration
void	setExecutor(java.util.concurrent.ExecutorService executor) Set the executor service for the task

Methods inherited from class java.lang.Object

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

Field Detail

taskName

public java.lang.String taskName

Constructor Detail

Task

public Task(java.lang.String taskName,
            Task[] children,
            java.lang.Object[] args,
            java.util.Map<java.lang.String,java.lang.Object> kwargs)

Task

public Task(java.lang.String taskName,
            java.lang.Object[] args,
            java.util.Map<java.lang.String,java.lang.Object> kwargs)

Task

public Task(java.lang.String taskName,
            Task[] children,
            java.lang.Object[] args,
            java.util.Map<java.lang.String,java.lang.Object> kwargs,
            java.lang.String backendURI,
            ConnectionInf connInf,
            Config config,
            BackendType backendType,
            java.util.concurrent.ExecutorService executor,
            java.lang.String correlationId,
            TaskMessageV2 message,
            Options options,
            int priority)

Method Detail

setConfig

public void setConfig(Config config)

Set the task configuration

Parameters:

config - The task configuration

setExecutor

public void setExecutor(java.util.concurrent.ExecutorService executor)

Set the executor service for the task

Parameters:

executor - The executor

executeChildren

public void executeChildren()

Execute the children

get

public AsyncResult get()

Bullds and calls get. Blocks until finished

Returns:

An asynchrounous result

delay

public java.util.concurrent.Future<AsyncResult> delay()

Delay configured with defaults

Returns:

An executing asynchrounous task

delay

public java.util.concurrent.Future<AsyncResult> delay(java.lang.Long delay)

Run the task on a specified delay

Parameters:

delay - The delay

Returns:

Executing Future returning an Asynchronouse result

applyAsync

public java.util.concurrent.Future<AsyncResult> applyAsync(java.lang.String queueName,
                                                           java.lang.Long softTimeLimit,
                                                           java.lang.Long hardTimeLimit,
                                                           java.lang.Long delay)

Apply a task asynchronously with some common options to be set

Parameters:

queueName - The queue name

softTimeLimit - The soft time limit

hardTimeLimit - The hard time limit

delay - The delay

Returns:

An asynchronous future

applyAsync

public java.util.concurrent.Future<AsyncResult> applyAsync(java.lang.Long softTimeLimit,
                                                           java.lang.Long hardTimeLimit,
                                                           java.lang.Long delay)

Apply a task asynchronously with some common options to be set

Parameters:

softTimeLimit - The soft time limit

hardTimeLimit - The hard time limit

delay - The delay

Returns:

An asynchronous future

applyAsync

public java.util.concurrent.Future<AsyncResult> applyAsync()

Calls delay for best practices

Returns:

A future containing an asynchronous result