Class QuartzTaskManager

  • All Implemented Interfaces:
    org.apache.synapse.task.TaskManager

    public class QuartzTaskManager
    extends Object
    implements org.apache.synapse.task.TaskManager
    • Field Detail

      • QUARTZ_CONF

        public static final String QUARTZ_CONF
        Property look up key for get a quartz configuration
        See Also:
        Constant Field Values
      • configProperties

        protected final Properties configProperties
    • Constructor Detail

      • QuartzTaskManager

        public QuartzTaskManager()
    • 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 name,
                                  org.apache.synapse.task.TaskDescription taskDescription)
        Specified by:
        reschedule in interface org.apache.synapse.task.TaskManager
      • delete

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

        public boolean pause​(String name)
        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 name)
        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 name)
        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
      • isTaskRunning

        public boolean isTaskRunning​(Object taskKey)
        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
      • 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
      • sendClusterMessage

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

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