public class ClusterRouterPoolActor extends akka.routing.RouterPoolActor implements ClusterRouterActor
Constructor and Description |
---|
ClusterRouterPoolActor(akka.actor.SupervisorStrategy supervisorStrategy,
ClusterRouterPoolSettings settings) |
Modifier and Type | Method and Description |
---|---|
void |
addRoutees()
Adds routees based on totalInstances and maxInstancesPerNode settings
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.Option<akka.actor.Address> |
selectDeploymentTarget() |
ClusterRouterPoolSettings |
settings() |
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cell, context, postRestart, postStop, preRestart, preStart, routingLogicController, self, sender, stopIfAllRouteesRemoved, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMember, availableNodes, cluster, clusterReceive, fullAddress, isAvailable, nodes, postStop, preStart, removeMember, satisfiesRole
public ClusterRouterPoolActor(akka.actor.SupervisorStrategy supervisorStrategy, ClusterRouterPoolSettings settings)
public ClusterRouterPoolSettings settings()
settings
in interface ClusterRouterActor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
receive
in class akka.routing.RouterPoolActor
public void addRoutees()
addRoutees
in interface ClusterRouterActor
public scala.Option<akka.actor.Address> selectDeploymentTarget()