Class ClusterGroupCommunicator
- java.lang.Object
-
- org.wso2.carbon.ntask.core.impl.clustered.ClusterGroupCommunicator
-
public class ClusterGroupCommunicator extends Object
This class represents the cluster group communicator used by clustered task managers.
-
-
Field Summary
Fields Modifier and Type Field Description static String
NTASK_P2P_COMM_EXECUTOR
static String
TASK_SERVER_COUNT_SYS_PROP
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addMyselfToGroup()
void
checkServers()
static ClusterGroupCommunicator
getInstance(String taskType)
List<String>
getMemberIds()
String
getStartupCounterName()
TaskService
getTaskService()
String
getTaskType()
boolean
isLeader()
<V> V
sendReceive(String memberId, TaskCall<V> taskCall)
-
-
-
Field Detail
-
NTASK_P2P_COMM_EXECUTOR
public static final String NTASK_P2P_COMM_EXECUTOR
- See Also:
- Constant Field Values
-
TASK_SERVER_COUNT_SYS_PROP
public static final String TASK_SERVER_COUNT_SYS_PROP
- See Also:
- Constant Field Values
-
-
Method Detail
-
getInstance
public static ClusterGroupCommunicator getInstance(String taskType) throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
addMyselfToGroup
public void addMyselfToGroup()
-
getStartupCounterName
public String getStartupCounterName()
-
getTaskType
public String getTaskType()
-
checkServers
public void checkServers() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
getTaskService
public TaskService getTaskService()
-
getMemberIds
public List<String> getMemberIds() throws org.wso2.carbon.ntask.common.TaskException
- Throws:
org.wso2.carbon.ntask.common.TaskException
-
isLeader
public boolean isLeader()
-
-