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.TasksListener
onTasksStarted
in interface TasksHandler.TasksListener
public void onTasksContinue()
TasksHandler.TasksListener
onTasksContinue
in interface TasksHandler.TasksListener
public void onTaskPreExecute(java.lang.Object id)
TasksHandler.TasksListener
onTaskPreExecute
in interface TasksHandler.TasksListener
id
- the task idpublic void onTaskPostExecute(java.lang.Object id)
TasksHandler.TasksListener
onTaskPostExecute
in interface TasksHandler.TasksListener
id
- the task idpublic void onTaskFailed(java.lang.Object id, java.lang.Exception exception)
TasksHandler.TasksListener
onTaskFailed
in interface TasksHandler.TasksListener
id
- the task idexception
- the exceptionpublic void onTaskSuccess(java.lang.Object id)
TasksHandler.TasksListener
onTaskSuccess
in interface TasksHandler.TasksListener
id
- the task idpublic void onTasksSuccess()
TasksHandler.TasksListener
onTasksSuccess
in interface TasksHandler.TasksListener
public void onTasksError()
TasksHandler.TasksListener
onTasksError
in interface TasksHandler.TasksListener
public void onTasksAutomaticFix(TasksHandler handler, StateContext<java.lang.String,java.lang.String> context)
TasksHandler.TasksListener
onTasksAutomaticFix
in interface TasksHandler.TasksListener
handler
- the tasks handlercontext
- the state context