public class Task
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
java.lang.String |
taskName |
| 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) |
| 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
|
public Task(java.lang.String taskName,
Task[] children,
java.lang.Object[] args,
java.util.Map<java.lang.String,java.lang.Object> kwargs)
public Task(java.lang.String taskName,
java.lang.Object[] args,
java.util.Map<java.lang.String,java.lang.Object> kwargs)
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)
public void setConfig(Config config)
config - The task configurationpublic void setExecutor(java.util.concurrent.ExecutorService executor)
executor - The executorpublic void executeChildren()
public AsyncResult get()
public java.util.concurrent.Future<AsyncResult> delay()
public java.util.concurrent.Future<AsyncResult> delay(java.lang.Long delay)
delay - The delaypublic java.util.concurrent.Future<AsyncResult> applyAsync(java.lang.String queueName, java.lang.Long softTimeLimit, java.lang.Long hardTimeLimit, java.lang.Long delay)
queueName - The queue namesoftTimeLimit - The soft time limithardTimeLimit - The hard time limitdelay - The delaypublic java.util.concurrent.Future<AsyncResult> applyAsync(java.lang.Long softTimeLimit, java.lang.Long hardTimeLimit, java.lang.Long delay)
softTimeLimit - The soft time limithardTimeLimit - The hard time limitdelay - The delaypublic java.util.concurrent.Future<AsyncResult> applyAsync()