public class ClusterGroupCommunicator extends Object
Modifier and Type | Field and Description |
---|---|
static String |
NTASK_P2P_COMM_EXECUTOR |
static String |
TASK_SERVER_COUNT_SYS_PROP |
Modifier and Type | Method and 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) |
public static final String NTASK_P2P_COMM_EXECUTOR
public static final String TASK_SERVER_COUNT_SYS_PROP
public static ClusterGroupCommunicator getInstance(String taskType) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public void addMyselfToGroup()
public String getStartupCounterName()
public String getTaskType()
public void checkServers() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public TaskService getTaskService()
public List<String> getMemberIds() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public boolean isLeader()
Copyright © 2024 WSO2. All rights reserved.