public class QuartzTaskManager
extends java.lang.Object
implements org.apache.synapse.task.TaskManager
Modifier and Type | Field and Description |
---|---|
protected java.util.Properties |
configProperties |
static java.lang.String |
QUARTZ_CONF
Property look up key for get a quartz configuration
|
Constructor and Description |
---|
QuartzTaskManager() |
Modifier and Type | Method and Description |
---|---|
void |
addObserver(org.apache.synapse.task.TaskManagerObserver o) |
boolean |
delete(java.lang.String nameGroup) |
java.util.Properties |
getConfigurationProperties() |
java.lang.String |
getName() |
java.lang.Object |
getProperty(java.lang.String name) |
java.lang.String |
getProviderClass() |
int |
getRunningTaskCount() |
org.apache.synapse.task.TaskDescription |
getTask(java.lang.String name) |
java.lang.String[] |
getTaskNames() |
boolean |
init(java.util.Properties properties) |
boolean |
isInitialized() |
boolean |
isTaskBlocked(java.lang.String taskName) |
boolean |
isTaskDeactivated(java.lang.String taskName) |
boolean |
isTaskExist(java.lang.String arg0) |
boolean |
isTaskRunning(java.lang.Object taskKey) |
boolean |
isTaskRunning(java.lang.String taskName) |
boolean |
pause(java.lang.String name) |
boolean |
pauseAll() |
boolean |
reschedule(java.lang.String name,
org.apache.synapse.task.TaskDescription taskDescription) |
boolean |
resume(java.lang.String name) |
boolean |
resumeAll() |
boolean |
schedule(org.apache.synapse.task.TaskDescription taskDescription) |
void |
sendClusterMessage(java.util.concurrent.Callable<java.lang.Void> task) |
void |
setConfigurationProperties(java.util.Properties properties) |
void |
setName(java.lang.String name) |
boolean |
setProperties(java.util.Map<java.lang.String,java.lang.Object> properties) |
boolean |
setProperty(java.lang.String name,
java.lang.Object property) |
boolean |
start() |
boolean |
stop() |
public static final java.lang.String QUARTZ_CONF
protected final java.util.Properties configProperties
public boolean schedule(org.apache.synapse.task.TaskDescription taskDescription)
schedule
in interface org.apache.synapse.task.TaskManager
public boolean reschedule(java.lang.String name, org.apache.synapse.task.TaskDescription taskDescription)
reschedule
in interface org.apache.synapse.task.TaskManager
public boolean delete(java.lang.String nameGroup)
delete
in interface org.apache.synapse.task.TaskManager
public boolean pause(java.lang.String name)
pause
in interface org.apache.synapse.task.TaskManager
public boolean pauseAll()
pauseAll
in interface org.apache.synapse.task.TaskManager
public boolean resume(java.lang.String name)
resume
in interface org.apache.synapse.task.TaskManager
public boolean resumeAll()
resumeAll
in interface org.apache.synapse.task.TaskManager
public org.apache.synapse.task.TaskDescription getTask(java.lang.String name)
getTask
in interface org.apache.synapse.task.TaskManager
public java.lang.String[] getTaskNames()
getTaskNames
in interface org.apache.synapse.task.TaskManager
public boolean init(java.util.Properties properties)
init
in interface org.apache.synapse.task.TaskManager
public boolean isInitialized()
isInitialized
in interface org.apache.synapse.task.TaskManager
public boolean start()
start
in interface org.apache.synapse.task.TaskManager
public boolean stop()
stop
in interface org.apache.synapse.task.TaskManager
public int getRunningTaskCount()
getRunningTaskCount
in interface org.apache.synapse.task.TaskManager
public boolean isTaskRunning(java.lang.Object taskKey)
isTaskRunning
in interface org.apache.synapse.task.TaskManager
public boolean setProperties(java.util.Map<java.lang.String,java.lang.Object> properties)
setProperties
in interface org.apache.synapse.task.TaskManager
public boolean setProperty(java.lang.String name, java.lang.Object property)
setProperty
in interface org.apache.synapse.task.TaskManager
public java.lang.Object getProperty(java.lang.String name)
getProperty
in interface org.apache.synapse.task.TaskManager
public void setName(java.lang.String name)
setName
in interface org.apache.synapse.task.TaskManager
public java.lang.String getName()
getName
in interface org.apache.synapse.task.TaskManager
public java.lang.String getProviderClass()
getProviderClass
in interface org.apache.synapse.task.TaskManager
public java.util.Properties getConfigurationProperties()
getConfigurationProperties
in interface org.apache.synapse.task.TaskManager
public void setConfigurationProperties(java.util.Properties properties)
setConfigurationProperties
in interface org.apache.synapse.task.TaskManager
public void addObserver(org.apache.synapse.task.TaskManagerObserver o)
addObserver
in interface org.apache.synapse.task.TaskManager
public boolean isTaskDeactivated(java.lang.String taskName)
isTaskDeactivated
in interface org.apache.synapse.task.TaskManager
public boolean isTaskBlocked(java.lang.String taskName)
isTaskBlocked
in interface org.apache.synapse.task.TaskManager
public boolean isTaskRunning(java.lang.String taskName)
isTaskRunning
in interface org.apache.synapse.task.TaskManager
public void sendClusterMessage(java.util.concurrent.Callable<java.lang.Void> task)
sendClusterMessage
in interface org.apache.synapse.task.TaskManager
public boolean isTaskExist(java.lang.String arg0)
isTaskExist
in interface org.apache.synapse.task.TaskManager
Copyright © 2005-2022 Apache Software Foundation. All Rights Reserved.