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

Class PrimaryOnlyPolicy

java.lang.Object

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

All Implemented Interfaces:

HAPolicy<Activation>

public class PrimaryOnlyPolicy
extends Object
implements HAPolicy<Activation>

Constructor Summary

Constructors

Constructor	Description
PrimaryOnlyPolicy()
PrimaryOnlyPolicy(ScaleDownPolicy scaleDownPolicy)

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	getScaleDownClustername()
int	getScaleDownCommitInterval()
String	getScaleDownGroupName()
ScaleDownPolicy	getScaleDownPolicy()
boolean	isBackup()
boolean	isSharedStore()
void	setScaleDownPolicy(ScaleDownPolicy scaleDownPolicy)

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

Constructor Details

PrimaryOnlyPolicy

public PrimaryOnlyPolicy()

PrimaryOnlyPolicy

public PrimaryOnlyPolicy(ScaleDownPolicy scaleDownPolicy)

Method Details

createActivation

public Activation 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<Activation>

getBackupGroupName

public String getBackupGroupName()

Specified by:

getBackupGroupName in interface HAPolicy<Activation>

getScaleDownGroupName

public String getScaleDownGroupName()

Specified by:

getScaleDownGroupName in interface HAPolicy<Activation>

getScaleDownClustername

public String getScaleDownClustername()

Specified by:

getScaleDownClustername in interface HAPolicy<Activation>

getScaleDownCommitInterval

public int getScaleDownCommitInterval()

Specified by:

getScaleDownCommitInterval in interface HAPolicy<Activation>

isSharedStore

public boolean isSharedStore()

Specified by:

isSharedStore in interface HAPolicy<Activation>

isBackup

public boolean isBackup()

Specified by:

isBackup in interface HAPolicy<Activation>

canScaleDown

public boolean canScaleDown()

Specified by:

canScaleDown in interface HAPolicy<Activation>

getScaleDownPolicy

public ScaleDownPolicy getScaleDownPolicy()

setScaleDownPolicy

public void setScaleDownPolicy(ScaleDownPolicy scaleDownPolicy)