Package org.apache.activemq.artemis.core.server.cluster.quorum

Class QuorumVoteServerConnect

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.quorum.QuorumVote<ServerConnectVote,Boolean>

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

public class QuorumVoteServerConnect
extends QuorumVote<ServerConnectVote,Boolean>

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

Field Summary

Fields

Modifier and Type	Field	Description
static final SimpleString	OLD_PRIMARY_FAILOVER_VOTE
static final SimpleString	PRIMARY_FAILOVER_VOTE	NOTE: The following String is used to identify the targetNode implementation at other servers.

Constructor Summary

Constructors

Constructor	Description
QuorumVoteServerConnect(int size, String targetNodeId)
QuorumVoteServerConnect(int size, String targetNodeId, boolean requestToStayActive, String connector)	active nodes | remaining nodes | majority | votes needed 1 | 0 | 0 | 0 2 | 1 | 1 | 1 3 | 2 | 2.5 | 2 4 | 3 | 3 | 3 5 | 4 | 3.5 | 3 6 | 5 | 4 | 4 n | n-1 | n/2 + 1 | n/2 + 1 rounded

Method Summary

Modifier and Type	Method	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
boolean	isRequestToStayActive()
Vote	notConnected()	if we cant connect to the node
void	vote(ServerConnectVote vote)	active nodes | remaining nodes | majority | votes needed 1 | 0 | 0 | 0 2 | 1 | 1 | 1 3 | 2 | 2.5 | 2 4 | 3 | 3 | 3 5 | 4 | 3.5 | 3 6 | 5 | 4 | 4 n | n-1 | n/2 + 1 | n/2 + 1 rounded

Methods inherited from class org.apache.activemq.artemis.core.server.cluster.quorum.QuorumVote

getName, getOldName

Methods inherited from class java.lang.Object

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

Field Details

PRIMARY_FAILOVER_VOTE

public static final SimpleString PRIMARY_FAILOVER_VOTE

NOTE: The following String is used to identify the targetNode implementation at other servers. Renaming such string would cause incompatibility changes.

OLD_PRIMARY_FAILOVER_VOTE

public static final SimpleString OLD_PRIMARY_FAILOVER_VOTE

Constructor Details

QuorumVoteServerConnect

public QuorumVoteServerConnect(int size,
 String targetNodeId,
 boolean requestToStayActive,
 String connector)

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

QuorumVoteServerConnect

public QuorumVoteServerConnect(int size,
 String targetNodeId)

Method Details

connected

public Vote connected()

if we can connect to a node

Specified by:

connected in class QuorumVote<ServerConnectVote,Boolean>

Returns:

the vote to use

notConnected

public Vote notConnected()

if we cant connect to the node

Specified by:

notConnected in class QuorumVote<ServerConnectVote,Boolean>

Returns:

the vote to use

vote

public void vote(ServerConnectVote vote)

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

Specified by:

vote in class QuorumVote<ServerConnectVote,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<ServerConnectVote,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<ServerConnectVote,Boolean>

Returns:

the voting decision

await

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

Throws:

InterruptedException

isRequestToStayActive

public boolean isRequestToStayActive()