public class ClusterHeartbeatManager extends Object
It periodically sends heartbeat to the other nodes and stores heartbeat timestamps per node when a heartbeat is received from other nodes. If enabled and required, it can send ping packets (an ICMP ping or an echo packet depending on the environment and settings).
If it detects a member is not live anymore, that member is kicked out of cluster.
Modifier and Type | Method and Description |
---|---|
long |
getHeartbeatIntervalMillis() |
long |
getLastHeartbeatTime(Member member) |
void |
handleHeartbeat(MembersViewMetadata senderMembersViewMetadata,
UUID receiverUuid,
long timestamp) |
void |
handleHeartbeatComplaint(MembersViewMetadata receiverMVMetadata,
MembersViewMetadata senderMVMetadata) |
void |
onHeartbeat(MemberImpl member,
long timestamp)
Accepts the heartbeat message from
member created at timestamp . |
public long getHeartbeatIntervalMillis()
public long getLastHeartbeatTime(Member member)
public void handleHeartbeat(MembersViewMetadata senderMembersViewMetadata, UUID receiverUuid, long timestamp)
public void handleHeartbeatComplaint(MembersViewMetadata receiverMVMetadata, MembersViewMetadata senderMVMetadata)
public void onHeartbeat(MemberImpl member, long timestamp)
member
created at timestamp
. The timestamp must be
related to the cluster clock, not the local clock. The heartbeat is ignored if the duration between
timestamp
and the current cluster time is more than GroupProperty.MAX_NO_HEARTBEAT_SECONDS
/2.
If the sending node is the master, this node will also calculate and set the cluster clock diff.member
- the member sending the heartbeattimestamp
- the timestamp when the heartbeat was createdCopyright © 2019 Hazelcast, Inc.. All rights reserved.