public interface TaskManager
Modifier and Type | Method and Description |
---|---|
void |
addObserver(TaskManagerObserver o)
Adds a new Observer to the list of observers of this task manager.
|
boolean |
delete(String name) |
Properties |
getConfigurationProperties() |
String |
getName() |
Object |
getProperty(String name) |
String |
getProviderClass() |
int |
getRunningTaskCount() |
TaskDescription |
getTask(String name) |
String[] |
getTaskNames() |
boolean |
init(Properties properties) |
boolean |
isInitialized() |
boolean |
isTaskBlocked(String taskName)
Checks whether the
Task with the given name is blocked without
giving the control back to the schedular. |
boolean |
isTaskDeactivated(String taskName)
Checks whether the
Task with the given name is deactivated. |
boolean |
isTaskExist(String taskName)
Checks whether the
Task with the given name exists. |
boolean |
isTaskRunning(Object taskKey) |
boolean |
isTaskRunning(String taskName)
Checks whether the
Task with the given name is running. |
boolean |
pause(String name) |
boolean |
pauseAll() |
boolean |
reschedule(String name,
TaskDescription taskDescription) |
boolean |
resume(String name) |
boolean |
resumeAll() |
boolean |
schedule(TaskDescription taskDescription)
Schedules a task on an external task scheduler based on the parameters of the TaskDescription.
|
void |
sendClusterMessage(Callable<Void> task)
Sends a cluster message, with the given
Callable task in this
cluster. |
void |
setConfigurationProperties(Properties properties) |
void |
setName(String name) |
boolean |
setProperties(Map<String,Object> properties) |
boolean |
setProperty(String name,
Object property) |
boolean |
start() |
boolean |
stop() |
boolean schedule(TaskDescription taskDescription)
taskDescription
- Contains parameters for the task scheduler. eg. target type, url, trigger parameters etc.boolean reschedule(String name, TaskDescription taskDescription)
boolean delete(String name)
boolean pause(String name)
boolean pauseAll()
boolean resume(String name)
boolean resumeAll()
TaskDescription getTask(String name)
String[] getTaskNames()
boolean init(Properties properties)
boolean isInitialized()
boolean start()
boolean stop()
int getRunningTaskCount()
boolean isTaskRunning(Object taskKey)
void setName(String name)
String getName()
String getProviderClass()
Properties getConfigurationProperties()
void setConfigurationProperties(Properties properties)
void addObserver(TaskManagerObserver o)
o
- New Observer to be registered or subscribed.boolean isTaskDeactivated(String taskName)
Task
with the given name is deactivated.taskName
- name of the Tasktrue
if the task is deactivated,false
otherwiseboolean isTaskBlocked(String taskName)
Task
with the given name is blocked without
giving the control back to the schedular.taskName
- name of the Tasktrue
if the task is blocked, false
otherwise.boolean isTaskRunning(String taskName)
Task
with the given name is running.taskName
- name of the Tasktrue
if the task is running,false
otherwise.void sendClusterMessage(Callable<Void> task)
Callable
task in this
cluster. The given Callable
task is executed by all the nodes in
the clustertask
- Callable
task to be executed by members in the
cluster.Copyright © 2005–2020 Apache Software Foundation. All rights reserved.