Package org.wso2.carbon.mediation.ntask
Class NTaskTaskManager
- java.lang.Object
-
- org.wso2.carbon.mediation.ntask.NTaskTaskManager
-
- All Implemented Interfaces:
org.apache.synapse.task.TaskManager
,org.wso2.carbon.core.ServerStartupHandler
,TaskServiceObserver
public class NTaskTaskManager extends Object implements org.apache.synapse.task.TaskManager, TaskServiceObserver, org.wso2.carbon.core.ServerStartupHandler
-
-
Field Summary
Fields Modifier and Type Field Description protected Properties
configProperties
-
Constructor Summary
Constructors Constructor Description NTaskTaskManager()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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 theTaskManager
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)
-
-
-
Field Detail
-
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 taskName, org.apache.synapse.task.TaskDescription taskDescription)
- Specified by:
reschedule
in interfaceorg.apache.synapse.task.TaskManager
-
delete
public boolean delete(String taskName)
- Specified by:
delete
in interfaceorg.apache.synapse.task.TaskManager
-
pause
public boolean pause(String taskName)
- 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 taskName)
- 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 taskName)
- 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
-
update
public boolean update(Map<String,Object> parameters)
- Specified by:
update
in interfaceTaskServiceObserver
-
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 o)
- 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
-
tenantId
public static int tenantId()
-
invoke
public void invoke()
- Specified by:
invoke
in interfaceorg.wso2.carbon.core.ServerStartupHandler
-
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
-
isTaskExist
public boolean isTaskExist(String taskName)
- Specified by:
isTaskExist
in interfaceorg.apache.synapse.task.TaskManager
-
sendClusterMessage
public void sendClusterMessage(Callable<Void> callable)
- Specified by:
sendClusterMessage
in interfaceorg.apache.synapse.task.TaskManager
-
registerListener
public void registerListener(org.wso2.carbon.ntask.core.impl.LocalTaskActionListener listener, String taskName)
Registers a listener to theTaskManager
to be notified when a local task is deleted.- Parameters:
listener
- the listener to be notifiedtaskName
- the task name for which the listener is bound
-
-