public abstract class AbstractQuartzTaskManager extends Object implements TaskManager
TaskManager
Modifier and Type | Class and Description |
---|---|
class |
AbstractQuartzTaskManager.TaskTriggerListener
Task trigger listener to check when a task is finished.
|
TaskManager.TaskState
Constructor and Description |
---|
AbstractQuartzTaskManager(TaskRepository taskRepository) |
Modifier and Type | Method and 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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deleteTask, getAllTasks, getTask, getTaskState, initStartupTasks, isTaskScheduled, pauseTask, registerTask, rescheduleTask, resumeTask, scheduleTask
public AbstractQuartzTaskManager(TaskRepository taskRepository) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public TaskRepository getTaskRepository()
protected org.quartz.Scheduler getScheduler()
public int getTenantId()
public String getTaskType()
protected TaskManager.TaskState getLocalTaskState(String taskName) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected Map<String,TaskManager.TaskState> getAllLocalTaskStates() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void registerLocalTask(TaskInfo taskInfo) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected boolean deleteLocalTask(String taskName, boolean removeRegistration) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void deleteLocalTasks() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void pauseLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void scheduleAllTasks() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void scheduleLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void scheduleLocalTask(String taskName, boolean paused) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void rescheduleLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected void resumeLocalTask(String taskName) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected boolean isLocalTaskScheduled(String taskName) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected List<TaskInfo> getAllLocalRunningTasks() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
protected List<TaskInfo> getAllFinishedTasks() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public void registerLocalTaskActionListener(LocalTaskActionListener listener, String taskName)
TaskManager
registerLocalTaskActionListener
in interface TaskManager
listener
- the listener to be notifiedtaskName
- the name of the task for which the listener should be registeredCopyright © 2017 WSO2. All rights reserved.