Class AbstractQuartzTaskManager

    • Constructor Detail

      • AbstractQuartzTaskManager

        public AbstractQuartzTaskManager​(TaskRepository taskRepository)
                                  throws org.wso2.carbon.ntask.common.TaskException
        Throws:
        org.wso2.carbon.ntask.common.TaskException
    • Method Detail

      • 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 interface TaskManager
        Parameters:
        listener - the listener to be notified
        taskName - the name of the task for which the listener should be registered