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

Class ScaleDownPolicy

java.lang.Object

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

public class ScaleDownPolicy
extends Object

Constructor Summary

Constructors

Constructor	Description
ScaleDownPolicy()
ScaleDownPolicy(String discoveryGroup, String groupName, String clusterName, boolean enabled, int commitInterval)
ScaleDownPolicy(List<String> connectors, String groupName, String clusterName, boolean enabled, int commitInterval)

Method Summary

Modifier and Type	Method	Description
String	getClusterName()
int	getCommitInterval()
List<String>	getConnectors()
String	getDiscoveryGroup()
String	getGroupName()
static ServerLocatorInternal	getScaleDownConnector(ScaleDownPolicy scaleDownPolicy, ActiveMQServer activeMQServer)
boolean	isEnabled()
void	setClusterName(String clusterName)
void	setCommitInterval(int commitInterval)
void	setConnectors(List<String> connectors)
void	setDiscoveryGroup(String discoveryGroup)
void	setEnabled(boolean enabled)
void	setGroupName(String groupName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ScaleDownPolicy

public ScaleDownPolicy()

ScaleDownPolicy

public ScaleDownPolicy(List<String> connectors,
 String groupName,
 String clusterName,
 boolean enabled,
 int commitInterval)

ScaleDownPolicy

public ScaleDownPolicy(String discoveryGroup,
 String groupName,
 String clusterName,
 boolean enabled,
 int commitInterval)

Method Details

getConnectors

public List<String> getConnectors()

setConnectors

public void setConnectors(List<String> connectors)

getDiscoveryGroup

public String getDiscoveryGroup()

setDiscoveryGroup

public void setDiscoveryGroup(String discoveryGroup)

getGroupName

public String getGroupName()

setGroupName

public void setGroupName(String groupName)

getClusterName

public String getClusterName()

setClusterName

public void setClusterName(String clusterName)

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean enabled)

getCommitInterval

public int getCommitInterval()

setCommitInterval

public void setCommitInterval(int commitInterval)

getScaleDownConnector

public static ServerLocatorInternal getScaleDownConnector(ScaleDownPolicy scaleDownPolicy,
 ActiveMQServer activeMQServer)
                                                   throws ActiveMQException

Throws:

ActiveMQException