public class ClusterGroupCommunicator extends Object implements com.hazelcast.core.MembershipListener
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() |
com.hazelcast.core.HazelcastInstance |
getHazelcast() |
static ClusterGroupCommunicator |
getInstance(String taskType) |
String |
getMemberId() |
List<String> |
getMemberIds() |
Map<String,com.hazelcast.core.Member> |
getMemberMap() |
String |
getStartupCounterName() |
TaskService |
getTaskService() |
String |
getTaskType() |
boolean |
isLeader() |
void |
memberAdded(com.hazelcast.core.MembershipEvent event) |
void |
memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent) |
void |
memberRemoved(com.hazelcast.core.MembershipEvent event) |
<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 com.hazelcast.core.HazelcastInstance getHazelcast()
public List<String> getMemberIds() throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public String getMemberId()
public boolean isLeader()
public <V> V sendReceive(String memberId, TaskCall<V> taskCall) throws org.wso2.carbon.ntask.common.TaskException
org.wso2.carbon.ntask.common.TaskException
public void memberAdded(com.hazelcast.core.MembershipEvent event)
memberAdded
in interface com.hazelcast.core.MembershipListener
public void memberRemoved(com.hazelcast.core.MembershipEvent event)
memberRemoved
in interface com.hazelcast.core.MembershipListener
public void memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent)
memberAttributeChanged
in interface com.hazelcast.core.MembershipListener
Copyright © 2019 WSO2. All rights reserved.