com.hazelcast.quorum.impl

Class QuorumServiceImpl

java.lang.Object

com.hazelcast.quorum.impl.QuorumServiceImpl

All Implemented Interfaces:

QuorumService, EventPublishingService<QuorumEvent,QuorumListener>, MembershipAwareService

public class QuorumServiceImpl
extends Object
implements EventPublishingService<QuorumEvent,QuorumListener>, MembershipAwareService, QuorumService

Service containing logic for cluster quorum.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
QuorumServiceImpl(NodeEngineImpl nodeEngine)

Method Summary

Methods

Modifier and Type	Method and Description
void	addQuorumListener(String name, QuorumListener listener)
void	dispatchEvent(QuorumEvent event, QuorumListener listener)
void	ensureQuorumPresent(Operation op)
Quorum	getQuorum(String quorumName) Returns the Quorum instance for a given quorum name.
void	memberAdded(MembershipServiceEvent event) Invoked when a new member is added to the cluster.
void	memberAttributeChanged(MemberAttributeServiceEvent event) Invoked when a member attribute is changed.
void	memberRemoved(MembershipServiceEvent event) Invoked when an existing member leaves the cluster.
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

Constructor Detail

QuorumServiceImpl

public QuorumServiceImpl(NodeEngineImpl nodeEngine)

Method Detail

start

public void start()

addQuorumListener

public void addQuorumListener(String name,
                     QuorumListener listener)

ensureQuorumPresent

public void ensureQuorumPresent(Operation op)

dispatchEvent

public void dispatchEvent(QuorumEvent event,
                 QuorumListener listener)

Specified by:

dispatchEvent in interface EventPublishingService<QuorumEvent,QuorumListener>

memberAdded

public void memberAdded(MembershipServiceEvent event)

Description copied from interface: MembershipAwareService

Invoked when a new member is added to the cluster. Should be non-blocking.

Specified by:

memberAdded in interface MembershipAwareService

Parameters:

event - the event for a new member added to the cluster

memberRemoved

public void memberRemoved(MembershipServiceEvent event)

Description copied from interface: MembershipAwareService

Invoked when an existing member leaves the cluster. Should be non-blocking.

Specified by:

memberRemoved in interface MembershipAwareService

Parameters:

event - the event for an existing member leaving the cluster

memberAttributeChanged

public void memberAttributeChanged(MemberAttributeServiceEvent event)

Description copied from interface: MembershipAwareService

Invoked when a member attribute is changed.

Specified by:

memberAttributeChanged in interface MembershipAwareService

Parameters:

event - the event for a member attribute being changed

getQuorum

public Quorum getQuorum(String quorumName)

Description copied from interface: QuorumService

Returns the Quorum instance for a given quorum name.

Specified by:

getQuorum in interface QuorumService

Parameters:

quorumName - name of the quorum

Returns:

Quorum