com.hazelcast.internal.cluster.impl

Class ClusterJoinManager

java.lang.Object

com.hazelcast.internal.cluster.impl.ClusterJoinManager

public class ClusterJoinManager
extends Object

ClusterJoinManager manages member join process.

If this node is not master, then it will answer with sending master node's address to a join request.

If this is master node, it will handle join request and notify all other members about newly joined member.

Constructor Summary

Constructors

Constructor and Description
ClusterJoinManager(Node node, ClusterServiceImpl clusterService, Lock clusterServiceLock)

Method Summary

Modifier and Type	Method and Description
void	answerMasterQuestion(JoinMessage joinMessage, Connection connection)
void	handleJoinRequest(JoinRequest joinRequest, Connection connection)
void	handleMaster(Address masterAddress, Address callerAddress)
boolean	isJoinInProgress()
boolean	sendJoinRequest(Address toAddress, boolean withCredentials)
boolean	sendMasterQuestion(Address toAddress)
boolean	setAsMaster()
boolean	setMasterAddress(Address master)
boolean	validateJoinMessage(JoinMessage joinMessage)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterJoinManager

public ClusterJoinManager(Node node,
                          ClusterServiceImpl clusterService,
                          Lock clusterServiceLock)

Method Detail

isJoinInProgress

public boolean isJoinInProgress()

handleJoinRequest

public void handleJoinRequest(JoinRequest joinRequest,
                              Connection connection)

validateJoinMessage

public boolean validateJoinMessage(JoinMessage joinMessage)
                            throws Exception

Throws:

Exception

sendJoinRequest

public boolean sendJoinRequest(Address toAddress,
                               boolean withCredentials)

handleMaster

public void handleMaster(Address masterAddress,
                         Address callerAddress)

setMasterAddress

public boolean setMasterAddress(Address master)

setAsMaster

public boolean setAsMaster()

sendMasterQuestion

public boolean sendMasterQuestion(Address toAddress)

answerMasterQuestion

public void answerMasterQuestion(JoinMessage joinMessage,
                                 Connection connection)