org.apache.activemq.artemis.core.server.cluster.qourum

Class QuorumVoteServerConnect

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.qourum.QuorumVote<BooleanVote,Boolean>

org.apache.activemq.artemis.core.server.cluster.qourum.QuorumVoteServerConnect

public class QuorumVoteServerConnect
extends QuorumVote<BooleanVote,Boolean>

A Qourum Vote for deciding if a replicated backup should become live.

Constructor Summary

Constructors

Constructor and Description
QuorumVoteServerConnect(int size, StorageManager storageManager) live nodes | remaining nodes | majority | votes needed 1 | 0 | 0 | 0 2 | 1 | 1 | 1 n | r = n-1 | n/2 + 1 | n/2 + 1 rounded 3 | 2 | 2.5 | 2 4 | 3 | 3 | 3 5 | 4 | 3.5 | 3 6 | 5 | 4 | 4

Method Summary

Modifier and Type	Method and Description
void	allVotesCast(Topology voteTopology) called by the QuorumManager when all the votes have been cast and received.
void	await(int latchTimeout, TimeUnit unit)
Vote	connected() if we can connect to a node
Boolean	getDecision() get the decion of the vote
SimpleString	getName() the name of this quorum vote, used for identifying the correct QuorumVoteHandler
Vote	notConnected() if we cant connect to the node
void	vote(BooleanVote vote) live nodes | remaining nodes | majority | votes needed 1 | 0 | 0 | 0 2 | 1 | 1 | 1 n | r = n-1 | n/2 + 1 | n/2 + 1 rounded 3 | 2 | 2.5 | 2 4 | 3 | 3 | 3 5 | 4 | 3.5 | 3 6 | 5 | 4 | 4

Methods inherited from class java.lang.Object

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

Constructor Detail

QuorumVoteServerConnect

public QuorumVoteServerConnect(int size,
                               StorageManager storageManager)

live nodes | remaining nodes | majority | votes needed 1 | 0 | 0 | 0 2 | 1 | 1 | 1 n | r = n-1 | n/2 + 1 | n/2 + 1 rounded 3 | 2 | 2.5 | 2 4 | 3 | 3 | 3 5 | 4 | 3.5 | 3 6 | 5 | 4 | 4

Method Detail

connected

public Vote connected()

if we can connect to a node

Specified by:

connected in class QuorumVote<BooleanVote,Boolean>

Returns:

notConnected

public Vote notConnected()

if we cant connect to the node

Specified by:

notConnected in class QuorumVote<BooleanVote,Boolean>

Returns:

vote

public void vote(BooleanVote vote)

live nodes | remaining nodes | majority | votes needed 1 | 0 | 0 | 0 2 | 1 | 1 | 1 n | r = n-1 | n/2 + 1 | n/2 + 1 rounded 3 | 2 | 2.5 | 2 4 | 3 | 3 | 3 5 | 4 | 3.5 | 3 6 | 5 | 4 | 4

Specified by:

vote in class QuorumVote<BooleanVote,Boolean>

Parameters:

vote - the vote to make.

allVotesCast

public void allVotesCast(Topology voteTopology)

Description copied from class: QuorumVote

called by the QuorumManager when all the votes have been cast and received.

Specified by:

allVotesCast in class QuorumVote<BooleanVote,Boolean>

Parameters:

voteTopology - the topology of where the votes were sent.

getDecision

public Boolean getDecision()

Description copied from class: QuorumVote

get the decion of the vote

Specified by:

getDecision in class QuorumVote<BooleanVote,Boolean>

Returns:

the voting decision

getName

public SimpleString getName()

Description copied from class: QuorumVote

the name of this quorum vote, used for identifying the correct QuorumVoteHandler

Overrides:

getName in class QuorumVote<BooleanVote,Boolean>

Returns:

the name of the wuorum vote

await

public void await(int latchTimeout,
                  TimeUnit unit)
           throws InterruptedException

Throws:

InterruptedException