Class NTaskTaskManager

  • All Implemented Interfaces:
    org.apache.synapse.task.TaskManager, org.wso2.carbon.core.ServerStartupHandler, TaskServiceObserver

    public class NTaskTaskManager
    extends Object
    implements org.apache.synapse.task.TaskManager, TaskServiceObserver, org.wso2.carbon.core.ServerStartupHandler
    • Field Detail

      • configProperties

        protected final Properties configProperties
    • Constructor Detail

      • NTaskTaskManager

        public NTaskTaskManager()
    • Method Detail

      • schedule

        public boolean schedule​(org.apache.synapse.task.TaskDescription taskDescription)
        Specified by:
        schedule in interface org.apache.synapse.task.TaskManager
      • reschedule

        public boolean reschedule​(String taskName,
                                  org.apache.synapse.task.TaskDescription taskDescription)
        Specified by:
        reschedule in interface org.apache.synapse.task.TaskManager
      • delete

        public boolean delete​(String taskName)
        Specified by:
        delete in interface org.apache.synapse.task.TaskManager
      • pause

        public boolean pause​(String taskName)
        Specified by:
        pause in interface org.apache.synapse.task.TaskManager
      • pauseAll

        public boolean pauseAll()
        Specified by:
        pauseAll in interface org.apache.synapse.task.TaskManager
      • resume

        public boolean resume​(String taskName)
        Specified by:
        resume in interface org.apache.synapse.task.TaskManager
      • resumeAll

        public boolean resumeAll()
        Specified by:
        resumeAll in interface org.apache.synapse.task.TaskManager
      • getTask

        public org.apache.synapse.task.TaskDescription getTask​(String taskName)
        Specified by:
        getTask in interface org.apache.synapse.task.TaskManager
      • getTaskNames

        public String[] getTaskNames()
        Specified by:
        getTaskNames in interface org.apache.synapse.task.TaskManager
      • init

        public boolean init​(Properties properties)
        Specified by:
        init in interface org.apache.synapse.task.TaskManager
      • isInitialized

        public boolean isInitialized()
        Specified by:
        isInitialized in interface org.apache.synapse.task.TaskManager
      • start

        public boolean start()
        Specified by:
        start in interface org.apache.synapse.task.TaskManager
      • stop

        public boolean stop()
        Specified by:
        stop in interface org.apache.synapse.task.TaskManager
      • getRunningTaskCount

        public int getRunningTaskCount()
        Specified by:
        getRunningTaskCount in interface org.apache.synapse.task.TaskManager
      • getRunningTaskList

        public List<String> getRunningTaskList()
      • isTaskRunning

        public boolean isTaskRunning​(Object o)
        Specified by:
        isTaskRunning in interface org.apache.synapse.task.TaskManager
      • setProperties

        public boolean setProperties​(Map<String,​Object> properties)
        Specified by:
        setProperties in interface org.apache.synapse.task.TaskManager
      • setProperty

        public boolean setProperty​(String name,
                                   Object property)
        Specified by:
        setProperty in interface org.apache.synapse.task.TaskManager
      • getProperty

        public Object getProperty​(String name)
        Specified by:
        getProperty in interface org.apache.synapse.task.TaskManager
      • setName

        public void setName​(String name)
        Specified by:
        setName in interface org.apache.synapse.task.TaskManager
      • getName

        public String getName()
        Specified by:
        getName in interface org.apache.synapse.task.TaskManager
      • getProviderClass

        public String getProviderClass()
        Specified by:
        getProviderClass in interface org.apache.synapse.task.TaskManager
      • getConfigurationProperties

        public Properties getConfigurationProperties()
        Specified by:
        getConfigurationProperties in interface org.apache.synapse.task.TaskManager
      • setConfigurationProperties

        public void setConfigurationProperties​(Properties properties)
        Specified by:
        setConfigurationProperties in interface org.apache.synapse.task.TaskManager
      • tenantId

        public static int tenantId()
      • invoke

        public void invoke()
        Specified by:
        invoke in interface org.wso2.carbon.core.ServerStartupHandler
      • addObserver

        public void addObserver​(org.apache.synapse.task.TaskManagerObserver o)
        Specified by:
        addObserver in interface org.apache.synapse.task.TaskManager
      • isTaskDeactivated

        public boolean isTaskDeactivated​(String taskName)
        Specified by:
        isTaskDeactivated in interface org.apache.synapse.task.TaskManager
      • isTaskBlocked

        public boolean isTaskBlocked​(String taskName)
        Specified by:
        isTaskBlocked in interface org.apache.synapse.task.TaskManager
      • isTaskRunning

        public boolean isTaskRunning​(String taskName)
        Specified by:
        isTaskRunning in interface org.apache.synapse.task.TaskManager
      • isTaskExist

        public boolean isTaskExist​(String taskName)
        Specified by:
        isTaskExist in interface org.apache.synapse.task.TaskManager
      • sendClusterMessage

        public void sendClusterMessage​(Callable<Void> callable)
        Specified by:
        sendClusterMessage in interface org.apache.synapse.task.TaskManager
      • registerListener

        public void registerListener​(org.wso2.carbon.ntask.core.impl.LocalTaskActionListener listener,
                                     String taskName)
        Registers a listener to the TaskManager to be notified when a local task is deleted.
        Parameters:
        listener - the listener to be notified
        taskName - the task name for which the listener is bound