Package org.apache.pekko.cluster.routing

Class ClusterRouterPoolSettings

java.lang.Object

org.apache.pekko.cluster.routing.ClusterRouterPoolSettings

All Implemented Interfaces:

Serializable, ClusterRouterSettingsBase, scala.Equals, scala.Product

public final class ClusterRouterPoolSettings
extends Object
implements scala.Product, Serializable, ClusterRouterSettingsBase

totalInstances of cluster router must be > 0 maxInstancesPerNode of cluster router must be > 0 maxInstancesPerNode of cluster router must be 1 when routeesPath is defined

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ClusterRouterPoolSettings(int totalInstances, int maxInstancesPerNode, boolean allowLocalRoutees, Set<String> useRoles)	Java API
ClusterRouterPoolSettings(int totalInstances, int maxInstancesPerNode, boolean allowLocalRoutees, scala.collection.immutable.Set<String> useRoles)

Method Summary

Modifier and Type	Method	Description
boolean	allowLocalRoutees()
static ClusterRouterPoolSettings	apply(int totalInstances, int maxInstancesPerNode, boolean allowLocalRoutees, String... useRoles)
static ClusterRouterPoolSettings	apply(int totalInstances, int maxInstancesPerNode, boolean allowLocalRoutees, scala.collection.immutable.Seq<String> useRoles)
static ClusterRouterPoolSettings	apply(int totalInstances, int maxInstancesPerNode, boolean allowLocalRoutees, scala.collection.immutable.Set<String> useRoles)
boolean	canEqual(Object that)
boolean	equals(Object obj)
static ClusterRouterPoolSettings	fromConfig(com.typesafe.config.Config config)
int	hashCode()
int	maxInstancesPerNode()
int	productArity()
Object	productElement(int n)
String	toString()
int	totalInstances()
static scala.Option<scala.Tuple4<Object,Object,Object,scala.collection.immutable.Set<String>>>	unapply(ClusterRouterPoolSettings settings)
scala.collection.immutable.Set<String>	useRoles()
ClusterRouterPoolSettings	withUseRoles(String... useRoles)	Java API
ClusterRouterPoolSettings	withUseRoles(Set<String> useRoles)	Java API
ClusterRouterPoolSettings	withUseRoles(scala.collection.immutable.Seq<String> useRoles)
ClusterRouterPoolSettings	withUseRoles(scala.collection.immutable.Set<String> useRoles)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

productElementName, productElementNames, productIterator, productPrefix

Constructor Details

ClusterRouterPoolSettings

public ClusterRouterPoolSettings(int totalInstances,
 int maxInstancesPerNode,
 boolean allowLocalRoutees,
 scala.collection.immutable.Set<String> useRoles)

ClusterRouterPoolSettings

public ClusterRouterPoolSettings(int totalInstances,
 int maxInstancesPerNode,
 boolean allowLocalRoutees,
 Set<String> useRoles)

Java API

Method Details

apply

public static ClusterRouterPoolSettings apply(int totalInstances,
 int maxInstancesPerNode,
 boolean allowLocalRoutees,
 String... useRoles)

apply

public static ClusterRouterPoolSettings apply(int totalInstances,
 int maxInstancesPerNode,
 boolean allowLocalRoutees,
 scala.collection.immutable.Set<String> useRoles)

apply

public static ClusterRouterPoolSettings apply(int totalInstances,
 int maxInstancesPerNode,
 boolean allowLocalRoutees,
 scala.collection.immutable.Seq<String> useRoles)

fromConfig

public static ClusterRouterPoolSettings fromConfig(com.typesafe.config.Config config)

unapply

public static scala.Option<scala.Tuple4<Object,Object,Object,scala.collection.immutable.Set<String>>> unapply(ClusterRouterPoolSettings settings)

withUseRoles

public ClusterRouterPoolSettings withUseRoles(String... useRoles)

Java API

totalInstances

public int totalInstances()

Specified by:

totalInstances in interface ClusterRouterSettingsBase

maxInstancesPerNode

public int maxInstancesPerNode()

allowLocalRoutees

public boolean allowLocalRoutees()

Specified by:

allowLocalRoutees in interface ClusterRouterSettingsBase

useRoles

public scala.collection.immutable.Set<String> useRoles()

Specified by:

useRoles in interface ClusterRouterSettingsBase

hashCode

public int hashCode()

Overrides:

hashCode in class Object

canEqual

public boolean canEqual(Object that)

Specified by:

canEqual in interface scala.Equals

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public Object productElement(int n)

Specified by:

productElement in interface scala.Product

equals

public boolean equals(Object obj)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

withUseRoles

public ClusterRouterPoolSettings withUseRoles(scala.collection.immutable.Set<String> useRoles)

withUseRoles

public ClusterRouterPoolSettings withUseRoles(scala.collection.immutable.Seq<String> useRoles)

withUseRoles

public ClusterRouterPoolSettings withUseRoles(Set<String> useRoles)

Java API