Package org.apache.activemq.artemis.core.server.routing.policies

Class LeastConnectionsPolicy

java.lang.Object

org.apache.activemq.artemis.core.server.routing.policies.AbstractPolicy

org.apache.activemq.artemis.core.server.routing.policies.RoundRobinPolicy

org.apache.activemq.artemis.core.server.routing.policies.LeastConnectionsPolicy

All Implemented Interfaces:

Policy

public class LeastConnectionsPolicy
extends RoundRobinPolicy

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONNECTION_COUNT_THRESHOLD
static final String	NAME
static final String	UPDATE_CONNECTION_COUNT_PROBE_NAME

Constructor Summary

Constructors

Constructor	Description
LeastConnectionsPolicy()

Method Summary

Modifier and Type	Method	Description
TargetProbe	getTargetProbe()
void	init(Map<String,String> properties)
Target	selectTarget(List<Target> targets, String key)

Methods inherited from class org.apache.activemq.artemis.core.server.routing.policies.AbstractPolicy

getName, getProperties

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.routing.policies.Policy

transformKey

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

UPDATE_CONNECTION_COUNT_PROBE_NAME

public static final String UPDATE_CONNECTION_COUNT_PROBE_NAME

See Also:

• Constant Field Values

CONNECTION_COUNT_THRESHOLD

public static final String CONNECTION_COUNT_THRESHOLD

See Also:

• Constant Field Values

Constructor Details

LeastConnectionsPolicy

public LeastConnectionsPolicy()

Method Details

getTargetProbe

public TargetProbe getTargetProbe()

Specified by:

getTargetProbe in interface Policy

Overrides:

getTargetProbe in class AbstractPolicy

init

public void init(Map<String,String> properties)

Specified by:

init in interface Policy

Overrides:

init in class AbstractPolicy

selectTarget

public Target selectTarget(List<Target> targets,
 String key)

Specified by:

selectTarget in interface Policy

Overrides:

selectTarget in class RoundRobinPolicy