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

Class ReplicatedPolicy

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.ha.ReplicatedPolicy

All Implemented Interfaces:

HAPolicy<PrimaryActivation>

public class ReplicatedPolicy
extends Object
implements HAPolicy<PrimaryActivation>

Constructor Summary

Constructors

Constructor	Description
ReplicatedPolicy(boolean checkForPrimaryServer, boolean allowAutoFailBack, long initialReplicationSyncTimeout, String groupName, String clusterName, ReplicaPolicy replicaPolicy, NetworkHealthCheck networkHealthCheck, boolean voteOnReplicationFailure, int quorumSize, int voteRetries, long voteRetryWait, int quorumVoteWait)
ReplicatedPolicy(boolean checkForPrimaryServer, String groupName, String clusterName, int maxSavedReplicatedJournalsSize, long initialReplicationSyncTimeout, NetworkHealthCheck networkHealthCheck, boolean voteOnReplicationFailure, int quorumSize, int voteRetries, long voteRetryWait, int quorumVoteWait, long retryReplicationWait)
ReplicatedPolicy(NetworkHealthCheck networkHealthCheck, int quorumVoteWait)

Method Summary

Modifier and Type	Method	Description
boolean	canScaleDown()
PrimaryActivation	createActivation(ActiveMQServerImpl server, boolean wasPrimary, Map<String,Object> activationParams, IOCriticalErrorListener ioCriticalErrorListener)	created the Activation associated with this policy.
String	getBackupGroupName()
String	getClusterName()
long	getFailbackDelay()	Deprecated.
String	getGroupName()
long	getInitialReplicationSyncTimeout()
int	getMaxSavedReplicatedJournalsSize()
int	getQuorumSize()
int	getQuorumVoteWait()
ReplicaPolicy	getReplicaPolicy()
long	getRetryReplicationWait()
boolean	isAllowAutoFailBack()
boolean	isBackup()
boolean	isCheckForPrimaryServer()
boolean	isSharedStore()
boolean	isVoteOnReplicationFailure()
void	setAllowAutoFailBack(boolean allowAutoFailBack)
void	setCheckForPrimaryServer(boolean checkForPrimaryServer)
void	setClusterName(String clusterName)
void	setFailbackDelay(long failbackDelay)	Deprecated.
void	setGroupName(String groupName)
void	setInitialReplicationSyncTimeout(long initialReplicationSyncTimeout)
void	setQuorumSize(int quorumSize)
void	setReplicaPolicy(ReplicaPolicy replicaPolicy)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.cluster.ha.HAPolicy

getScaleDownClustername, getScaleDownCommitInterval, getScaleDownGroupName, isWaitForActivation, useQuorumManager

Constructor Details

ReplicatedPolicy

public ReplicatedPolicy(NetworkHealthCheck networkHealthCheck,
 int quorumVoteWait)

ReplicatedPolicy

public ReplicatedPolicy(boolean checkForPrimaryServer,
 String groupName,
 String clusterName,
 int maxSavedReplicatedJournalsSize,
 long initialReplicationSyncTimeout,
 NetworkHealthCheck networkHealthCheck,
 boolean voteOnReplicationFailure,
 int quorumSize,
 int voteRetries,
 long voteRetryWait,
 int quorumVoteWait,
 long retryReplicationWait)

ReplicatedPolicy

public ReplicatedPolicy(boolean checkForPrimaryServer,
 boolean allowAutoFailBack,
 long initialReplicationSyncTimeout,
 String groupName,
 String clusterName,
 ReplicaPolicy replicaPolicy,
 NetworkHealthCheck networkHealthCheck,
 boolean voteOnReplicationFailure,
 int quorumSize,
 int voteRetries,
 long voteRetryWait,
 int quorumVoteWait)

Method Details

isCheckForPrimaryServer

public boolean isCheckForPrimaryServer()

setCheckForPrimaryServer

public void setCheckForPrimaryServer(boolean checkForPrimaryServer)

isAllowAutoFailBack

public boolean isAllowAutoFailBack()

getFailbackDelay

@Deprecated
public long getFailbackDelay()

Deprecated.

setFailbackDelay

@Deprecated
public void setFailbackDelay(long failbackDelay)

Deprecated.

getInitialReplicationSyncTimeout

public long getInitialReplicationSyncTimeout()

setInitialReplicationSyncTimeout

public void setInitialReplicationSyncTimeout(long initialReplicationSyncTimeout)

getClusterName

public String getClusterName()

setClusterName

public void setClusterName(String clusterName)

getReplicaPolicy

public ReplicaPolicy getReplicaPolicy()

setReplicaPolicy

public void setReplicaPolicy(ReplicaPolicy replicaPolicy)

getBackupGroupName

public String getBackupGroupName()

Specified by:

getBackupGroupName in interface HAPolicy<PrimaryActivation>

getGroupName

public String getGroupName()

setGroupName

public void setGroupName(String groupName)

isSharedStore

public boolean isSharedStore()

Specified by:

isSharedStore in interface HAPolicy<PrimaryActivation>

isBackup

public boolean isBackup()

Specified by:

isBackup in interface HAPolicy<PrimaryActivation>

canScaleDown

public boolean canScaleDown()

Specified by:

canScaleDown in interface HAPolicy<PrimaryActivation>

setAllowAutoFailBack

public void setAllowAutoFailBack(boolean allowAutoFailBack)

isVoteOnReplicationFailure

public boolean isVoteOnReplicationFailure()

createActivation

public PrimaryActivation createActivation(ActiveMQServerImpl server,
 boolean wasPrimary,
 Map<String,Object> activationParams,
 IOCriticalErrorListener ioCriticalErrorListener)

Description copied from interface: HAPolicy

created the Activation associated with this policy.

Specified by:

createActivation in interface HAPolicy<PrimaryActivation>

getQuorumSize

public int getQuorumSize()

setQuorumSize

public void setQuorumSize(int quorumSize)

getQuorumVoteWait

public int getQuorumVoteWait()

getRetryReplicationWait

public long getRetryReplicationWait()

getMaxSavedReplicatedJournalsSize

public int getMaxSavedReplicatedJournalsSize()