com.communote.server.core.tasks

Class TaskExecutionCleaner

java.lang.Object

com.communote.server.core.tasks.TaskExecutionCleaner

public class TaskExecutionCleaner
extends Object

Tool to clean up tasks that couldn't be stopped or marked as failed at the end of the task execution for instance because of missing DB connections. The Cleaner will be triggered by the TaskExecutionCleanupJob.

Author:

Communote GmbH - http://www.communote.com/

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEY_TASK_EXECUTION_CLEANER Key under which this instance is stored in the context of the scheduler instance

Constructor Summary

Constructors

Constructor and Description
TaskExecutionCleaner() Constructor.

Method Summary

Modifier and Type	Method and Description
void	addTaskToFail(String taskName) Add a task that should be marked as failed.
void	addTaskToStop(String taskName) Add a task that should be stopped.
void	processTasksToFail() Process all tasks that should be marked as failed.
void	processTasksToStop() Process all tasks that should be stopped.

Methods inherited from class java.lang.Object

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

Field Detail

KEY_TASK_EXECUTION_CLEANER

public static final String KEY_TASK_EXECUTION_CLEANER

Key under which this instance is stored in the context of the scheduler instance

See Also:

Constant Field Values

Constructor Detail

TaskExecutionCleaner

public TaskExecutionCleaner()

Constructor.

Method Detail

addTaskToFail

public void addTaskToFail(String taskName)

Add a task that should be marked as failed.

Parameters:

taskName - the unique name of the task

addTaskToStop

public void addTaskToStop(String taskName)

Add a task that should be stopped.

Parameters:

taskName - the unique name of the task

processTasksToFail

public void processTasksToFail()

Process all tasks that should be marked as failed.

processTasksToStop

public void processTasksToStop()

Process all tasks that should be stopped.