public class ClusterRouterPoolActor extends RouterPoolActor implements ClusterRouterActor
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
ClusterRouterPoolActor(SupervisorStrategy supervisorStrategy,
ClusterRouterPoolSettings settings) |
Modifier and Type | Method and Description |
---|---|
void |
addRoutees()
Adds routees based on totalInstances and maxInstancesPerNode settings
|
scala.collection.immutable.SortedSet<Address> |
nodes() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic.
|
scala.Option<Address> |
selectDeploymentTarget() |
ClusterRouterPoolSettings |
settings() |
pool, supervisorStrategy
cell, context, preRestart, routingLogicController, self, stopIfAllRouteesRemoved
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMember, availableNodes, cluster, clusterReceive, fullAddress, isAvailable, postStop, preStart, removeMember, satisfiesRole
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preStart, sender, unhandled
public ClusterRouterPoolActor(SupervisorStrategy supervisorStrategy, ClusterRouterPoolSettings settings)
public scala.collection.immutable.SortedSet<Address> nodes()
nodes
in interface ClusterRouterActor
public ClusterRouterPoolSettings settings()
settings
in interface ClusterRouterActor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
receive
in interface Actor
receive
in class RouterPoolActor
public void addRoutees()
addRoutees
in interface ClusterRouterActor
public scala.Option<Address> selectDeploymentTarget()