public static class TasksHandler.TasksListenerAdapter extends java.lang.Object implements TasksHandler.TasksListener
TasksHandler.TasksListener.| Constructor and Description |
|---|
TasksListenerAdapter() |
| Modifier and Type | Method and Description |
|---|---|
void |
onTaskFailed(java.lang.Object id,
java.lang.Exception exception)
Called when task execution result an error of any kind.
|
void |
onTaskPostExecute(java.lang.Object id)
Called after tasks has been executed regardless if task
execution succeeded or not.
|
void |
onTaskPreExecute(java.lang.Object id)
Called before tasks is about to be executed.
|
void |
onTasksAutomaticFix(TasksHandler handler,
StateContext<java.lang.String,java.lang.String> context)
Called when tasks execution resulted an error and AUTOMATIC state
is entered.
|
void |
onTasksContinue()
Called when some of a tasks in DAGs failed to execute and tasks
execution in going to continue.
|
void |
onTasksError()
Called when after an execution of full DAGs if some of the
tasks executed with an error.
|
void |
onTasksStarted()
Called when all DAGs have either never executed or previous
execution was fully successful.
|
void |
onTasksSuccess()
Called when all tasks has been executed successfully.
|
void |
onTaskSuccess(java.lang.Object id)
Called when task execution result without errors.
|
public void onTasksStarted()
TasksHandler.TasksListeneronTasksStarted in interface TasksHandler.TasksListenerpublic void onTasksContinue()
TasksHandler.TasksListeneronTasksContinue in interface TasksHandler.TasksListenerpublic void onTaskPreExecute(java.lang.Object id)
TasksHandler.TasksListeneronTaskPreExecute in interface TasksHandler.TasksListenerid - the task idpublic void onTaskPostExecute(java.lang.Object id)
TasksHandler.TasksListeneronTaskPostExecute in interface TasksHandler.TasksListenerid - the task idpublic void onTaskFailed(java.lang.Object id,
java.lang.Exception exception)
TasksHandler.TasksListeneronTaskFailed in interface TasksHandler.TasksListenerid - the task idexception - the exceptionpublic void onTaskSuccess(java.lang.Object id)
TasksHandler.TasksListeneronTaskSuccess in interface TasksHandler.TasksListenerid - the task idpublic void onTasksSuccess()
TasksHandler.TasksListeneronTasksSuccess in interface TasksHandler.TasksListenerpublic void onTasksError()
TasksHandler.TasksListeneronTasksError in interface TasksHandler.TasksListenerpublic void onTasksAutomaticFix(TasksHandler handler, StateContext<java.lang.String,java.lang.String> context)
TasksHandler.TasksListeneronTasksAutomaticFix in interface TasksHandler.TasksListenerhandler - the tasks handlercontext - the state context