com.bigdata.quorum

Class MockQuorumFixture.MockQuorum.MockQuorumWatcher

java.lang.Object

com.bigdata.quorum.AbstractQuorum.QuorumWatcherBase

com.bigdata.quorum.MockQuorumFixture.MockQuorum.MockQuorumWatcher

All Implemented Interfaces:

QuorumListener, QuorumWatcher<S,C>

Enclosing class:

MockQuorumFixture.MockQuorum<S extends Remote,C extends QuorumMember<S>>

protected class MockQuorumFixture.MockQuorum.MockQuorumWatcher
extends AbstractQuorum.QuorumWatcherBase
implements QuorumListener

Watcher propagates state changes observed in the MockQuorumFixture2 to the MockQuorumFixture.MockQuorum.

Note: This relies on the QuorumEvent mechanism. If there are errors, they will be logged rather than propagated. This actually mimics what happens if a client spams zookeeper with some bad data. The errors will be observed in the QuorumWatcher of the clients monitoring that quorum.

Field Summary

Fields inherited from class com.bigdata.quorum.AbstractQuorum.QuorumWatcherBase

logicalServiceId

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MockQuorumFixture.MockQuorum.MockQuorumWatcher(String logicalServiceUUID)

Method Summary

Methods

Modifier and Type	Method and Description
void	notify(QuorumEvent e) Propagate state change to our quorum.
protected void	start() Method is invoked by AbstractQuorum.start(QuorumClient) and provides the QuorumWatcher with an opportunity to setup discovery (such as zookeeper watchers) and read the initial state of the distributed quorum, causing it to be reflected on the AbstractQuorum internal state.
protected void	terminate() Method is invoked by AbstractQuorum.terminate() and provides the QuorumWatcher with an opportunity to terminate asynchronous processing and tear down any resources it may be using.

Methods inherited from class com.bigdata.quorum.AbstractQuorum.QuorumWatcherBase

castVote, clearToken, doAction, memberAdd, memberRemove, pipelineAdd, pipelineRemove, serviceJoin, serviceLeave, setToken, withdrawVote

Methods inherited from class java.lang.Object

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

Constructor Detail

MockQuorumFixture.MockQuorum.MockQuorumWatcher

protected MockQuorumFixture.MockQuorum.MockQuorumWatcher(String logicalServiceUUID)

Method Detail

notify

public void notify(QuorumEvent e)

Propagate state change to our quorum.

Specified by:

notify in interface QuorumListener

start

protected void start()

Description copied from class: AbstractQuorum.QuorumWatcherBase

Method is invoked by AbstractQuorum.start(QuorumClient) and provides the QuorumWatcher with an opportunity to setup discovery (such as zookeeper watchers) and read the initial state of the distributed quorum, causing it to be reflected on the AbstractQuorum internal state.

Overrides:

start in class AbstractQuorum.QuorumWatcherBase

terminate

protected void terminate()

Description copied from class: AbstractQuorum.QuorumWatcherBase

Method is invoked by AbstractQuorum.terminate() and provides the QuorumWatcher with an opportunity to terminate asynchronous processing and tear down any resources it may be using.

Overrides:

terminate in class AbstractQuorum.QuorumWatcherBase