Class ClusterGroupCommunicator


  • public class ClusterGroupCommunicator
    extends Object
    This class represents the cluster group communicator used by clustered task managers.
    • 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
      • getMemberIds

        public List<String> getMemberIds()
                                  throws org.wso2.carbon.ntask.common.TaskException
        Throws:
        org.wso2.carbon.ntask.common.TaskException
      • isLeader

        public boolean isLeader()
      • sendReceive

        public <V> V sendReceive​(String memberId,
                                 TaskCall<V> taskCall)
                          throws org.wso2.carbon.ntask.common.TaskException
        Throws:
        org.wso2.carbon.ntask.common.TaskException