com.hazelcast.quorum.impl

Class AbstractPingAwareQuorumFunction

java.lang.Object

com.hazelcast.quorum.impl.AbstractPingAwareQuorumFunction

All Implemented Interfaces:

HazelcastInstanceAware, MembershipListener, PingAware, EventListener

Direct Known Subclasses:

ProbabilisticQuorumFunction, RecentlyActiveQuorumFunction

public abstract class AbstractPingAwareQuorumFunction
extends Object
implements PingAware, HazelcastInstanceAware, MembershipListener

Base class for quorum functions which may use ICMP failure detector information to determine presence of quorum.

Constructor Summary

Constructors

Constructor and Description
AbstractPingAwareQuorumFunction()

Method Summary

Modifier and Type	Method and Description
protected boolean	isAlivePerIcmp(Member member)
void	memberAdded(MembershipEvent membershipEvent) Invoked when a new member is added to the cluster.
void	memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) Invoked when an attribute of a member was changed.
void	memberRemoved(MembershipEvent membershipEvent) Invoked when an existing member leaves the cluster.
void	onPingLost(Member member) Notifies the QuorumFunction of ping loss.
void	onPingRestored(Member member) Notifies the QuorumFunction of a successful ping after one or more pings to that member were lost.
void	setHazelcastInstance(HazelcastInstance hazelcastInstance) Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPingAwareQuorumFunction

public AbstractPingAwareQuorumFunction()

Method Detail

setHazelcastInstance

public void setHazelcastInstance(HazelcastInstance hazelcastInstance)

Description copied from interface: HazelcastInstanceAware

Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Specified by:

setHazelcastInstance in interface HazelcastInstanceAware

Parameters:

hazelcastInstance - the HazelcastInstance reference

onPingLost

public void onPingLost(Member member)

Description copied from interface: PingAware

Notifies the QuorumFunction of ping loss.

Specified by:

onPingLost in interface PingAware

Parameters:

member - member which was not pinged successfully

onPingRestored

public void onPingRestored(Member member)

Description copied from interface: PingAware

Notifies the QuorumFunction of a successful ping after one or more pings to that member were lost.

Specified by:

onPingRestored in interface PingAware

Parameters:

member - member which was pinged successfully

memberAdded

public void memberAdded(MembershipEvent membershipEvent)

Description copied from interface: MembershipListener

Invoked when a new member is added to the cluster.

Specified by:

memberAdded in interface MembershipListener

Parameters:

membershipEvent - membership event

memberAttributeChanged

public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent)

Description copied from interface: MembershipListener

Invoked when an attribute of a member was changed.

Specified by:

memberAttributeChanged in interface MembershipListener

Parameters:

memberAttributeEvent - member attribute event when an attribute of a member was changed

memberRemoved

public void memberRemoved(MembershipEvent membershipEvent)

Description copied from interface: MembershipListener

Invoked when an existing member leaves the cluster.

Specified by:

memberRemoved in interface MembershipListener

Parameters:

membershipEvent - membership event when an existing member leaves the cluster

isAlivePerIcmp

protected boolean isAlivePerIcmp(Member member)