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<LiveActivation>

public class ReplicatedPolicy
extends Object
implements HAPolicy<LiveActivation>

Constructor Summary

Constructors

Constructor and Description
ReplicatedPolicy(boolean checkForLiveServer, boolean allowAutoFailBack, long initialReplicationSyncTimeout, String groupName, String clusterName, ReplicaPolicy replicaPolicy, NetworkHealthCheck networkHealthCheck)
ReplicatedPolicy(boolean checkForLiveServer, String groupName, String clusterName, long initialReplicationSyncTimeout, NetworkHealthCheck networkHealthCheck)
ReplicatedPolicy(NetworkHealthCheck networkHealthCheck)

Method Summary

Modifier and Type	Method and Description
boolean	canScaleDown()
LiveActivation	createActivation(ActiveMQServerImpl server, boolean wasLive, Map<String,Object> activationParams, ActiveMQServerImpl.ShutdownOnCriticalErrorListener shutdownOnCriticalIO)
String	getBackupGroupName()
String	getClusterName()
long	getFailbackDelay() Deprecated.
String	getGroupName()
long	getInitialReplicationSyncTimeout()
ReplicaPolicy	getReplicaPolicy()
String	getScaleDownClustername()
String	getScaleDownGroupName()
boolean	isAllowAutoFailBack()
boolean	isBackup()
boolean	isCheckForLiveServer()
boolean	isSharedStore()
void	setAllowAutoFailBack(boolean allowAutoFailBack)
void	setCheckForLiveServer(boolean checkForLiveServer)
void	setClusterName(String clusterName)
void	setFailbackDelay(long failbackDelay) Deprecated.
void	setGroupName(String groupName)
void	setInitialReplicationSyncTimeout(long initialReplicationSyncTimeout)
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

isWaitForActivation

Constructor Detail

ReplicatedPolicy

public ReplicatedPolicy(NetworkHealthCheck networkHealthCheck)

ReplicatedPolicy

public ReplicatedPolicy(boolean checkForLiveServer,
                        String groupName,
                        String clusterName,
                        long initialReplicationSyncTimeout,
                        NetworkHealthCheck networkHealthCheck)

ReplicatedPolicy

public ReplicatedPolicy(boolean checkForLiveServer,
                        boolean allowAutoFailBack,
                        long initialReplicationSyncTimeout,
                        String groupName,
                        String clusterName,
                        ReplicaPolicy replicaPolicy,
                        NetworkHealthCheck networkHealthCheck)

Method Detail

isCheckForLiveServer

public boolean isCheckForLiveServer()

setCheckForLiveServer

public void setCheckForLiveServer(boolean checkForLiveServer)

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<LiveActivation>

getGroupName

public String getGroupName()

getScaleDownGroupName

public String getScaleDownGroupName()

Specified by:

getScaleDownGroupName in interface HAPolicy<LiveActivation>

setGroupName

public void setGroupName(String groupName)

isSharedStore

public boolean isSharedStore()

Specified by:

isSharedStore in interface HAPolicy<LiveActivation>

isBackup

public boolean isBackup()

Specified by:

isBackup in interface HAPolicy<LiveActivation>

canScaleDown

public boolean canScaleDown()

Specified by:

canScaleDown in interface HAPolicy<LiveActivation>

getScaleDownClustername

public String getScaleDownClustername()

Specified by:

getScaleDownClustername in interface HAPolicy<LiveActivation>

setAllowAutoFailBack

public void setAllowAutoFailBack(boolean allowAutoFailBack)

createActivation

public LiveActivation createActivation(ActiveMQServerImpl server,
                                       boolean wasLive,
                                       Map<String,Object> activationParams,
                                       ActiveMQServerImpl.ShutdownOnCriticalErrorListener shutdownOnCriticalIO)

Specified by:

createActivation in interface HAPolicy<LiveActivation>