com.bigdata.quorum

Interface QuorumStateChangeEvent

All Known Implementing Classes:

QCE

public interface QuorumStateChangeEvent

Event data equivalent to the QuorumStateChangeListener API. This interface makes it possible to enqueue these messages and then process them asynchronously.

Author:

Bryan Thompson

See Also:

QuorumStateChangeListener

Method Summary

Methods

Modifier and Type	Method and Description
UUID[]	getDownstreamOldAndNew() Return the old and new downstream UUIDs.
QuorumStateChangeEventEnum	getEventType() The type of event and never null.
long	getLastCommitTimeConsensus() The last commit time consensus.
UUID	getLeaderId() Return the UUID of the quorum leader.
long	getToken() Return the token on which the quorum met.

Method Detail

getEventType

QuorumStateChangeEventEnum getEventType()

The type of event and never null.

getDownstreamOldAndNew

UUID[] getDownstreamOldAndNew()

Return the old and new downstream UUIDs.

Returns:

An array of two elements. [0] is the old downstream service UUID. [1] is the new downstream service UUID.

Throws:

UnsupportedOperationException - unless getEventType() is QuorumStateChangeEventEnum.PIPELINE_CHANGE.

See Also:

QuorumStateChangeListener.pipelineChange(UUID, UUID)

getLastCommitTimeConsensus

long getLastCommitTimeConsensus()

The last commit time consensus.

Returns:

The last commit time consensus value.

Throws:

UnsupportedOperationException - unless getEventType() is QuorumStateChangeEventEnum.CONSENSUS.

See Also:

QuorumStateChangeListener.consensus(long)

getToken

long getToken()

Return the token on which the quorum met.

Returns:

The token.

Throws:

UnsupportedOperationException - unless getEventType() is QuorumStateChangeEventEnum.QUORUM_MEET.

See Also:

QuorumStateChangeListener.quorumMeet(long, UUID)

getLeaderId

UUID getLeaderId()

Return the UUID of the quorum leader.

Returns:

The UUID of the quorum leader.

Throws:

UnsupportedOperationException - unless getEventType() is QuorumStateChangeEventEnum.QUORUM_MEET.

See Also:

QuorumStateChangeListener.quorumMeet(long, UUID)