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

Class ReplicaPolicy

java.lang.Object

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

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

All Implemented Interfaces:

HAPolicy<Activation>

public class ReplicaPolicy
extends BackupPolicy

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.cluster.ha.BackupPolicy

scaleDownPolicy

Constructor Summary

Constructors

Constructor	Description
ReplicaPolicy(String clusterName, int maxSavedReplicatedJournalsSize, String groupName, boolean restartBackup, boolean allowFailback, long initialReplicationSyncTimeout, ScaleDownPolicy scaleDownPolicy, NetworkHealthCheck networkHealthCheck, boolean voteOnReplicationFailure, int quorumSize, int voteRetries, long voteRetryWait, int quorumVoteWait, long retryReplicationWait)
ReplicaPolicy(String clusterName, int maxSavedReplicatedJournalsSize, String groupName, ReplicatedPolicy replicatedPolicy, NetworkHealthCheck networkHealthCheck, int quorumVoteWait)
ReplicaPolicy(NetworkHealthCheck networkHealthCheck, int quorumVoteWait)
ReplicaPolicy(NetworkHealthCheck networkHealthCheck, ReplicatedPolicy replicatedPolicy, int quorumVoteWait)

Method Summary

Modifier and Type	Method	Description
boolean	canScaleDown()
Activation	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()
ReplicatedPolicy	getReplicatedPolicy()
long	getRetryReplicationWait()
int	getVoteRetries()
long	getVoteRetryWait()
boolean	isAllowFailback()
boolean	isRestartBackup()
boolean	isSharedStore()
boolean	isVoteOnReplicationFailure()
void	setAllowFailback(boolean allowFailback)
void	setClusterName(String clusterName)
void	setFailbackDelay(long failbackDelay)	Deprecated.
void	setGroupName(String groupName)
void	setInitialReplicationSyncTimeout(long initialReplicationSyncTimeout)
void	setMaxSavedReplicatedJournalsSize(int maxSavedReplicatedJournalsSize)
void	setQuorumSize(int quorumSize)
void	setReplicatedPolicy(ReplicatedPolicy replicatedPolicy)
void	setRestartBackup(boolean restartBackup)
void	setretryReplicationWait(long retryReplicationWait)
void	setVoteOnReplicationFailure(boolean voteOnReplicationFailure)
void	setVoteRetries(int voteRetries)
void	setVoteRetryWait(long voteRetryWait)

Methods inherited from class org.apache.activemq.artemis.core.server.cluster.ha.BackupPolicy

getScaleDownGroupName, getScaleDownPolicy, isBackup, setScaleDownPolicy

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, isWaitForActivation, useQuorumManager

Constructor Details

ReplicaPolicy

public ReplicaPolicy(NetworkHealthCheck networkHealthCheck,
 int quorumVoteWait)

ReplicaPolicy

public ReplicaPolicy(NetworkHealthCheck networkHealthCheck,
 ReplicatedPolicy replicatedPolicy,
 int quorumVoteWait)

ReplicaPolicy

public ReplicaPolicy(String clusterName,
 int maxSavedReplicatedJournalsSize,
 String groupName,
 boolean restartBackup,
 boolean allowFailback,
 long initialReplicationSyncTimeout,
 ScaleDownPolicy scaleDownPolicy,
 NetworkHealthCheck networkHealthCheck,
 boolean voteOnReplicationFailure,
 int quorumSize,
 int voteRetries,
 long voteRetryWait,
 int quorumVoteWait,
 long retryReplicationWait)

ReplicaPolicy

public ReplicaPolicy(String clusterName,
 int maxSavedReplicatedJournalsSize,
 String groupName,
 ReplicatedPolicy replicatedPolicy,
 NetworkHealthCheck networkHealthCheck,
 int quorumVoteWait)

Method Details

getClusterName

public String getClusterName()

setClusterName

public void setClusterName(String clusterName)

getMaxSavedReplicatedJournalsSize

public int getMaxSavedReplicatedJournalsSize()

setMaxSavedReplicatedJournalsSize

public void setMaxSavedReplicatedJournalsSize(int maxSavedReplicatedJournalsSize)

getReplicatedPolicy

public ReplicatedPolicy getReplicatedPolicy()

setReplicatedPolicy

public void setReplicatedPolicy(ReplicatedPolicy replicatedPolicy)

getBackupGroupName

public String getBackupGroupName()

getGroupName

public String getGroupName()

setGroupName

public void setGroupName(String groupName)

isRestartBackup

public boolean isRestartBackup()

Overrides:

isRestartBackup in class BackupPolicy

setRestartBackup

public void setRestartBackup(boolean restartBackup)

Overrides:

setRestartBackup in class BackupPolicy

isSharedStore

public boolean isSharedStore()

canScaleDown

public boolean canScaleDown()

isAllowFailback

public boolean isAllowFailback()

setAllowFailback

public void setAllowFailback(boolean allowFailback)

getFailbackDelay

@Deprecated
public long getFailbackDelay()

Deprecated.

setFailbackDelay

@Deprecated
public void setFailbackDelay(long failbackDelay)

Deprecated.

getInitialReplicationSyncTimeout

public long getInitialReplicationSyncTimeout()

setInitialReplicationSyncTimeout

public void setInitialReplicationSyncTimeout(long initialReplicationSyncTimeout)

createActivation

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

Description copied from interface: HAPolicy

created the Activation associated with this policy.

Throws:

Exception

setQuorumSize

public void setQuorumSize(int quorumSize)

getQuorumSize

public int getQuorumSize()

setVoteOnReplicationFailure

public void setVoteOnReplicationFailure(boolean voteOnReplicationFailure)

isVoteOnReplicationFailure

public boolean isVoteOnReplicationFailure()

setVoteRetries

public void setVoteRetries(int voteRetries)

setVoteRetryWait

public void setVoteRetryWait(long voteRetryWait)

getVoteRetries

public int getVoteRetries()

getVoteRetryWait

public long getVoteRetryWait()

getQuorumVoteWait

public int getQuorumVoteWait()

getRetryReplicationWait

public long getRetryReplicationWait()

setretryReplicationWait

public void setretryReplicationWait(long retryReplicationWait)