Package org.wso2.carbon.ntask.core.impl
Class AbstractQuartzTaskManager
- java.lang.Object
-
- org.wso2.carbon.ntask.core.impl.AbstractQuartzTaskManager
-
- All Implemented Interfaces:
TaskManager
- Direct Known Subclasses:
ClusteredTaskManager
,StandaloneTaskManager
public abstract class AbstractQuartzTaskManager extends Object implements TaskManager
This class represents an abstract class implementation of TaskManager based on Quartz Scheduler.- See Also:
TaskManager
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
AbstractQuartzTaskManager.TaskTriggerListener
Task trigger listener to check when a task is finished.-
Nested classes/interfaces inherited from interface org.wso2.carbon.ntask.core.TaskManager
TaskManager.TaskState
-
-
Constructor Summary
Constructors Constructor Description AbstractQuartzTaskManager(TaskRepository taskRepository)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
deleteLocalTask(String taskName, boolean removeRegistration)
protected void
deleteLocalTasks()
protected List<TaskInfo>
getAllFinishedTasks()
protected List<TaskInfo>
getAllLocalRunningTasks()
protected Map<String,TaskManager.TaskState>
getAllLocalTaskStates()
protected TaskManager.TaskState
getLocalTaskState(String taskName)
protected org.quartz.Scheduler
getScheduler()
TaskRepository
getTaskRepository()
String
getTaskType()
int
getTenantId()
protected boolean
isLocalTaskScheduled(String taskName)
protected void
pauseLocalTask(String taskName)
protected void
registerLocalTask(TaskInfo taskInfo)
void
registerLocalTaskActionListener(LocalTaskActionListener listener, String taskName)
Registers a listener to be notified when an action is performed on a task.protected void
rescheduleLocalTask(String taskName)
protected void
resumeLocalTask(String taskName)
protected void
scheduleAllTasks()
protected void
scheduleLocalTask(String taskName)
protected void
scheduleLocalTask(String taskName, boolean paused)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.wso2.carbon.ntask.core.TaskManager
deleteTask, getAllTasks, getTask, getTaskState, initStartupTasks, isTaskScheduled, pauseTask, registerTask, rescheduleTask, resumeTask, scheduleTask
-
-
-
-
Constructor Detail
-
AbstractQuartzTaskManager
public AbstractQuartzTaskManager(TaskRepository taskRepository) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
-
Method Detail
-
getTaskRepository
public TaskRepository getTaskRepository()
-
getScheduler
protected org.quartz.Scheduler getScheduler()
-
getTenantId
public int getTenantId()
-
getTaskType
public String getTaskType()
-
getLocalTaskState
protected TaskManager.TaskState getLocalTaskState(String taskName) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
getAllLocalTaskStates
protected Map<String,TaskManager.TaskState> getAllLocalTaskStates() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
registerLocalTask
protected void registerLocalTask(TaskInfo taskInfo) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
deleteLocalTask
protected boolean deleteLocalTask(String taskName, boolean removeRegistration) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
deleteLocalTasks
protected void deleteLocalTasks() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
pauseLocalTask
protected void pauseLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
scheduleAllTasks
protected void scheduleAllTasks() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
scheduleLocalTask
protected void scheduleLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
scheduleLocalTask
protected void scheduleLocalTask(String taskName, boolean paused) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
rescheduleLocalTask
protected void rescheduleLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
resumeLocalTask
protected void resumeLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
isLocalTaskScheduled
protected boolean isLocalTaskScheduled(String taskName) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
getAllLocalRunningTasks
protected List<TaskInfo> getAllLocalRunningTasks() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
getAllFinishedTasks
protected List<TaskInfo> getAllFinishedTasks() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
registerLocalTaskActionListener
public void registerLocalTaskActionListener(LocalTaskActionListener listener, String taskName)
Description copied from interface:TaskManager
Registers a listener to be notified when an action is performed on a task.- Specified by:
registerLocalTaskActionListener
in interfaceTaskManager
- Parameters:
listener
- the listener to be notifiedtaskName
- the name of the task for which the listener should be registered
-
-