Package org.wso2.carbon.mediation.ntask
Class MultiMemberTaskLocationResolver
- java.lang.Object
-
- org.wso2.carbon.mediation.ntask.MultiMemberTaskLocationResolver
-
- All Implemented Interfaces:
org.wso2.carbon.ntask.core.TaskLocationResolver
public class MultiMemberTaskLocationResolver extends Object implements org.wso2.carbon.ntask.core.TaskLocationResolver
Use thisTaskLocationResolver
only if you need to run the same task on multiple worker nodes concurrently. For each worker/member where you need to run the task concurrently, you may have to call thisTaskLocationResolver
and get the member location index value. Then you can schedule that particular task on the selected member node.
-
-
Constructor Summary
Constructors Constructor Description MultiMemberTaskLocationResolver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getLocation(org.wso2.carbon.ntask.core.TaskServiceContext ctx, org.wso2.carbon.ntask.core.TaskInfo taskInfo)
void
init(Map<String,String> properties)
-
-
-
Method Detail
-
init
public void init(Map<String,String> properties) throws org.wso2.carbon.ntask.common.TaskException
- Specified by:
init
in interfaceorg.wso2.carbon.ntask.core.TaskLocationResolver
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
getLocation
public int getLocation(org.wso2.carbon.ntask.core.TaskServiceContext ctx, org.wso2.carbon.ntask.core.TaskInfo taskInfo) throws org.wso2.carbon.ntask.common.TaskException
- Specified by:
getLocation
in interfaceorg.wso2.carbon.ntask.core.TaskLocationResolver
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
-