public class RecentlyActiveQuorumFunction extends AbstractPingAwareQuorumFunction implements HeartbeatAware, QuorumFunction, MembershipListener
heartbeatToleranceMillis
milliseconds before current time.Constructor and Description |
---|
RecentlyActiveQuorumFunction(int quorumSize,
int heartbeatToleranceMillis) |
Modifier and Type | Method and Description |
---|---|
boolean |
apply(Collection<Member> members)
Determines if quorum is present based on the current list of members in the cluster.
|
boolean |
equals(Object o) |
int |
getHeartbeatToleranceMillis() |
int |
hashCode() |
void |
memberRemoved(MembershipEvent membershipEvent)
Invoked when an existing member leaves the cluster.
|
void |
onHeartbeat(Member member,
long timestamp)
Notifies of a received heartbeat.
|
isAlivePerIcmp, memberAdded, memberAttributeChanged, onPingLost, onPingRestored, setHazelcastInstance
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
memberAdded, memberAttributeChanged
public RecentlyActiveQuorumFunction(int quorumSize, int heartbeatToleranceMillis)
public boolean apply(Collection<Member> members)
QuorumFunction
apply
in interface QuorumFunction
members
- snapshot of current member listpublic void onHeartbeat(Member member, long timestamp)
HeartbeatAware
QuorumFunction.apply(Collection)
so
the QuorumFunction
can update its internal state before deciding on quorum presence.onHeartbeat
in interface HeartbeatAware
member
- member from which heartbeat was receivedtimestamp
- timestmap on which heartbeat was receivedpublic void memberRemoved(MembershipEvent membershipEvent)
MembershipListener
memberRemoved
in interface MembershipListener
memberRemoved
in class AbstractPingAwareQuorumFunction
membershipEvent
- membership event when an existing member leaves the clusterpublic int getHeartbeatToleranceMillis()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.