Class QuartzTaskManager
- java.lang.Object
-
- org.apache.synapse.startup.quartz.QuartzTaskManager
-
- All Implemented Interfaces:
org.apache.synapse.task.TaskManager
public class QuartzTaskManager extends Object implements org.apache.synapse.task.TaskManager
-
-
Field Summary
Fields Modifier and Type Field Description protected Properties
configProperties
static String
QUARTZ_CONF
Property look up key for get a quartz configuration
-
Constructor Summary
Constructors Constructor Description QuartzTaskManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addObserver(org.apache.synapse.task.TaskManagerObserver o)
boolean
delete(String nameGroup)
Properties
getConfigurationProperties()
String
getName()
Object
getProperty(String name)
String
getProviderClass()
int
getRunningTaskCount()
org.apache.synapse.task.TaskDescription
getTask(String name)
String[]
getTaskNames()
boolean
init(Properties properties)
boolean
isInitialized()
boolean
isTaskBlocked(String taskName)
boolean
isTaskDeactivated(String taskName)
boolean
isTaskExist(String arg0)
boolean
isTaskRunning(Object taskKey)
boolean
isTaskRunning(String taskName)
boolean
pause(String name)
boolean
pauseAll()
boolean
reschedule(String name, org.apache.synapse.task.TaskDescription taskDescription)
boolean
resume(String name)
boolean
resumeAll()
boolean
schedule(org.apache.synapse.task.TaskDescription taskDescription)
void
sendClusterMessage(Callable<Void> task)
void
setConfigurationProperties(Properties properties)
void
setName(String name)
boolean
setProperties(Map<String,Object> properties)
boolean
setProperty(String name, Object property)
boolean
start()
boolean
stop()
-
-
-
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
-
-
Method Detail
-
schedule
public boolean schedule(org.apache.synapse.task.TaskDescription taskDescription)
- Specified by:
schedule
in interfaceorg.apache.synapse.task.TaskManager
-
reschedule
public boolean reschedule(String name, org.apache.synapse.task.TaskDescription taskDescription)
- Specified by:
reschedule
in interfaceorg.apache.synapse.task.TaskManager
-
delete
public boolean delete(String nameGroup)
- Specified by:
delete
in interfaceorg.apache.synapse.task.TaskManager
-
pause
public boolean pause(String name)
- Specified by:
pause
in interfaceorg.apache.synapse.task.TaskManager
-
pauseAll
public boolean pauseAll()
- Specified by:
pauseAll
in interfaceorg.apache.synapse.task.TaskManager
-
resume
public boolean resume(String name)
- Specified by:
resume
in interfaceorg.apache.synapse.task.TaskManager
-
resumeAll
public boolean resumeAll()
- Specified by:
resumeAll
in interfaceorg.apache.synapse.task.TaskManager
-
getTask
public org.apache.synapse.task.TaskDescription getTask(String name)
- Specified by:
getTask
in interfaceorg.apache.synapse.task.TaskManager
-
getTaskNames
public String[] getTaskNames()
- Specified by:
getTaskNames
in interfaceorg.apache.synapse.task.TaskManager
-
init
public boolean init(Properties properties)
- Specified by:
init
in interfaceorg.apache.synapse.task.TaskManager
-
isInitialized
public boolean isInitialized()
- Specified by:
isInitialized
in interfaceorg.apache.synapse.task.TaskManager
-
start
public boolean start()
- Specified by:
start
in interfaceorg.apache.synapse.task.TaskManager
-
stop
public boolean stop()
- Specified by:
stop
in interfaceorg.apache.synapse.task.TaskManager
-
getRunningTaskCount
public int getRunningTaskCount()
- Specified by:
getRunningTaskCount
in interfaceorg.apache.synapse.task.TaskManager
-
isTaskRunning
public boolean isTaskRunning(Object taskKey)
- Specified by:
isTaskRunning
in interfaceorg.apache.synapse.task.TaskManager
-
setProperties
public boolean setProperties(Map<String,Object> properties)
- Specified by:
setProperties
in interfaceorg.apache.synapse.task.TaskManager
-
setProperty
public boolean setProperty(String name, Object property)
- Specified by:
setProperty
in interfaceorg.apache.synapse.task.TaskManager
-
getProperty
public Object getProperty(String name)
- Specified by:
getProperty
in interfaceorg.apache.synapse.task.TaskManager
-
setName
public void setName(String name)
- Specified by:
setName
in interfaceorg.apache.synapse.task.TaskManager
-
getName
public String getName()
- Specified by:
getName
in interfaceorg.apache.synapse.task.TaskManager
-
getProviderClass
public String getProviderClass()
- Specified by:
getProviderClass
in interfaceorg.apache.synapse.task.TaskManager
-
getConfigurationProperties
public Properties getConfigurationProperties()
- Specified by:
getConfigurationProperties
in interfaceorg.apache.synapse.task.TaskManager
-
setConfigurationProperties
public void setConfigurationProperties(Properties properties)
- Specified by:
setConfigurationProperties
in interfaceorg.apache.synapse.task.TaskManager
-
addObserver
public void addObserver(org.apache.synapse.task.TaskManagerObserver o)
- Specified by:
addObserver
in interfaceorg.apache.synapse.task.TaskManager
-
isTaskDeactivated
public boolean isTaskDeactivated(String taskName)
- Specified by:
isTaskDeactivated
in interfaceorg.apache.synapse.task.TaskManager
-
isTaskBlocked
public boolean isTaskBlocked(String taskName)
- Specified by:
isTaskBlocked
in interfaceorg.apache.synapse.task.TaskManager
-
isTaskRunning
public boolean isTaskRunning(String taskName)
- Specified by:
isTaskRunning
in interfaceorg.apache.synapse.task.TaskManager
-
sendClusterMessage
public void sendClusterMessage(Callable<Void> task)
- Specified by:
sendClusterMessage
in interfaceorg.apache.synapse.task.TaskManager
-
isTaskExist
public boolean isTaskExist(String arg0)
- Specified by:
isTaskExist
in interfaceorg.apache.synapse.task.TaskManager
-
-