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 and Description
ReplicaPolicy(NetworkHealthCheck networkHealthCheck)
ReplicaPolicy(NetworkHealthCheck networkHealthCheck, ReplicatedPolicy replicatedPolicy)
ReplicaPolicy(String clusterName, int maxSavedReplicatedJournalsSize, String groupName, boolean restartBackup, boolean allowFailback, long initialReplicationSyncTimeout, ScaleDownPolicy scaleDownPolicy, NetworkHealthCheck networkHealthCheck)
ReplicaPolicy(String clusterName, int maxSavedReplicatedJournalsSize, String groupName, ReplicatedPolicy replicatedPolicy, NetworkHealthCheck networkHealthCheck)

Method Summary

Modifier and Type	Method and Description
boolean	canScaleDown()
Activation	createActivation(ActiveMQServerImpl server, boolean wasLive, Map<String,Object> activationParams, ActiveMQServerImpl.ShutdownOnCriticalErrorListener shutdownOnCriticalIO)
String	getBackupGroupName()
String	getClusterName()
long	getFailbackDelay() Deprecated.
String	getGroupName()
long	getInitialReplicationSyncTimeout()
int	getMaxSavedReplicatedJournalsSize()
ReplicatedPolicy	getReplicatedPolicy()
boolean	isAllowFailback()
boolean	isRestartBackup()
boolean	isSharedStore()
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	setReplicatedPolicy(ReplicatedPolicy replicatedPolicy)
void	setRestartBackup(boolean restartBackup)

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

getScaleDownClustername, 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

isWaitForActivation

Constructor Detail

ReplicaPolicy

public ReplicaPolicy(NetworkHealthCheck networkHealthCheck)

ReplicaPolicy

public ReplicaPolicy(NetworkHealthCheck networkHealthCheck,
                     ReplicatedPolicy replicatedPolicy)

ReplicaPolicy

public ReplicaPolicy(String clusterName,
                     int maxSavedReplicatedJournalsSize,
                     String groupName,
                     boolean restartBackup,
                     boolean allowFailback,
                     long initialReplicationSyncTimeout,
                     ScaleDownPolicy scaleDownPolicy,
                     NetworkHealthCheck networkHealthCheck)

ReplicaPolicy

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

Method Detail

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 wasLive,
                                   Map<String,Object> activationParams,
                                   ActiveMQServerImpl.ShutdownOnCriticalErrorListener shutdownOnCriticalIO)
                            throws Exception

Throws:

Exception