Class ReplicationPrimaryPolicy
java.lang.Object
org.apache.activemq.artemis.core.server.cluster.ha.ReplicationPrimaryPolicy
- All Implemented Interfaces:
HAPolicy<ReplicationPrimaryActivation>
public class ReplicationPrimaryPolicy
extends Object
implements HAPolicy<ReplicationPrimaryActivation>
-
Method Summary
Modifier and TypeMethodDescriptionbooleancreateActivation(ActiveMQServerImpl server, boolean wasPrimary, Map<String, Object> activationParams, IOCriticalErrorListener shutdownOnCriticalIO) created the Activation associated with this policy.longbooleanbooleanisBackup()booleanbooleanbooleanstatic ReplicationPrimaryPolicywith(ReplicationPrimaryPolicyConfiguration configuration) It creates a primary policy that never allow auto fail-back.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.activemq.artemis.core.server.cluster.ha.HAPolicy
getScaleDownClustername, getScaleDownCommitInterval, getScaleDownGroupName
-
Method Details
-
with
It creates a primary policy that never allow auto fail-back.It's meant to be used for natural-born primary brokers: its backup policy is set to always try to fail-back.
-
getBackupPolicy
-
createActivation
public ReplicationPrimaryActivation createActivation(ActiveMQServerImpl server, boolean wasPrimary, Map<String, Object> activationParams, IOCriticalErrorListener shutdownOnCriticalIO) throws ExceptionDescription copied from interface:HAPolicycreated the Activation associated with this policy.- Specified by:
createActivationin interfaceHAPolicy<ReplicationPrimaryActivation>- Throws:
Exception
-
isBackup
public boolean isBackup()- Specified by:
isBackupin interfaceHAPolicy<ReplicationPrimaryActivation>
-
isWaitForActivation
public boolean isWaitForActivation()- Specified by:
isWaitForActivationin interfaceHAPolicy<ReplicationPrimaryActivation>
-
canScaleDown
public boolean canScaleDown()- Specified by:
canScaleDownin interfaceHAPolicy<ReplicationPrimaryActivation>
-
getBackupGroupName
- Specified by:
getBackupGroupNamein interfaceHAPolicy<ReplicationPrimaryActivation>
-
isAllowAutoFailBack
public boolean isAllowAutoFailBack() -
getClusterName
-
getInitialReplicationSyncTimeout
public long getInitialReplicationSyncTimeout() -
getGroupName
-
useQuorumManager
public boolean useQuorumManager()- Specified by:
useQuorumManagerin interfaceHAPolicy<ReplicationPrimaryActivation>
-
getCoordinationId
-