public class NTaskTaskManager extends Object implements org.apache.synapse.task.TaskManager, TaskServiceObserver, org.wso2.carbon.core.ServerStartupHandler
Modifier and Type | Field and Description |
---|---|
protected Properties |
configProperties |
Constructor and Description |
---|
NTaskTaskManager() |
Modifier and Type | Method and Description |
---|---|
void |
addObserver(org.apache.synapse.task.TaskManagerObserver o) |
boolean |
delete(String taskName) |
Properties |
getConfigurationProperties() |
String |
getName() |
Object |
getProperty(String name) |
String |
getProviderClass() |
int |
getRunningTaskCount() |
List<String> |
getRunningTaskList() |
org.apache.synapse.task.TaskDescription |
getTask(String taskName) |
String[] |
getTaskNames() |
boolean |
init(Properties properties) |
void |
invoke() |
boolean |
isInitialized() |
boolean |
isTaskBlocked(String taskName) |
boolean |
isTaskDeactivated(String taskName) |
boolean |
isTaskExist(String taskName) |
boolean |
isTaskRunning(Object o) |
boolean |
isTaskRunning(String taskName) |
boolean |
pause(String taskName) |
boolean |
pauseAll() |
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. |
boolean |
reschedule(String taskName,
org.apache.synapse.task.TaskDescription taskDescription) |
boolean |
resume(String taskName) |
boolean |
resumeAll() |
boolean |
schedule(org.apache.synapse.task.TaskDescription taskDescription) |
void |
sendClusterMessage(Callable<Void> callable) |
void |
setConfigurationProperties(Properties properties) |
void |
setName(String name) |
boolean |
setProperties(Map<String,Object> properties) |
boolean |
setProperty(String name,
Object property) |
boolean |
start() |
boolean |
stop() |
static int |
tenantId() |
boolean |
update(Map<String,Object> parameters) |
protected final Properties configProperties
public boolean schedule(org.apache.synapse.task.TaskDescription taskDescription)
schedule
in interface org.apache.synapse.task.TaskManager
public boolean reschedule(String taskName, org.apache.synapse.task.TaskDescription taskDescription)
reschedule
in interface org.apache.synapse.task.TaskManager
public boolean delete(String taskName)
delete
in interface org.apache.synapse.task.TaskManager
public boolean pause(String taskName)
pause
in interface org.apache.synapse.task.TaskManager
public boolean pauseAll()
pauseAll
in interface org.apache.synapse.task.TaskManager
public boolean resume(String taskName)
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(String taskName)
getTask
in interface org.apache.synapse.task.TaskManager
public String[] getTaskNames()
getTaskNames
in interface org.apache.synapse.task.TaskManager
public boolean init(Properties properties)
init
in interface org.apache.synapse.task.TaskManager
public boolean update(Map<String,Object> parameters)
update
in interface TaskServiceObserver
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(Object o)
isTaskRunning
in interface org.apache.synapse.task.TaskManager
public boolean setProperties(Map<String,Object> properties)
setProperties
in interface org.apache.synapse.task.TaskManager
public boolean setProperty(String name, Object property)
setProperty
in interface org.apache.synapse.task.TaskManager
public Object getProperty(String name)
getProperty
in interface org.apache.synapse.task.TaskManager
public void setName(String name)
setName
in interface org.apache.synapse.task.TaskManager
public String getName()
getName
in interface org.apache.synapse.task.TaskManager
public String getProviderClass()
getProviderClass
in interface org.apache.synapse.task.TaskManager
public Properties getConfigurationProperties()
getConfigurationProperties
in interface org.apache.synapse.task.TaskManager
public void setConfigurationProperties(Properties properties)
setConfigurationProperties
in interface org.apache.synapse.task.TaskManager
public static int tenantId()
public void invoke()
invoke
in interface org.wso2.carbon.core.ServerStartupHandler
public void addObserver(org.apache.synapse.task.TaskManagerObserver o)
addObserver
in interface org.apache.synapse.task.TaskManager
public boolean isTaskDeactivated(String taskName)
isTaskDeactivated
in interface org.apache.synapse.task.TaskManager
public boolean isTaskBlocked(String taskName)
isTaskBlocked
in interface org.apache.synapse.task.TaskManager
public boolean isTaskRunning(String taskName)
isTaskRunning
in interface org.apache.synapse.task.TaskManager
public boolean isTaskExist(String taskName)
isTaskExist
in interface org.apache.synapse.task.TaskManager
public void sendClusterMessage(Callable<Void> callable)
sendClusterMessage
in interface org.apache.synapse.task.TaskManager
public void registerListener(org.wso2.carbon.ntask.core.impl.LocalTaskActionListener listener, String taskName)
TaskManager
to be notified when a local task is
deleted.listener
- the listener to be notifiedtaskName
- the task name for which the listener is boundCopyright © 2017 WSO2. All rights reserved.