public class ClusterRouterGroupActor extends akka.routing.RouterActor implements ClusterRouterActor
Constructor and Description |
---|
ClusterRouterGroupActor(ClusterRouterGroupSettings settings) |
Modifier and Type | Method and Description |
---|---|
void |
addRoutees()
Adds routees based on totalInstances and maxInstancesPerNode settings
|
akka.routing.Group |
group() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
void |
removeMember(Member member) |
scala.Option<scala.Tuple2<akka.actor.Address,java.lang.String>> |
selectDeploymentTarget() |
ClusterRouterGroupSettings |
settings() |
scala.collection.immutable.Map<akka.actor.Address,scala.collection.immutable.Set<java.lang.String>> |
usedRouteePaths() |
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, supervisorStrategy, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMember, availableNodes, cluster, clusterReceive, fullAddress, isAvailable, nodes, postStop, preStart, satisfiesRole
public ClusterRouterGroupActor(ClusterRouterGroupSettings settings)
public ClusterRouterGroupSettings settings()
settings
in interface ClusterRouterActor
public akka.routing.Group group()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
receive
in class akka.routing.RouterActor
public scala.collection.immutable.Map<akka.actor.Address,scala.collection.immutable.Set<java.lang.String>> usedRouteePaths()
public void addRoutees()
addRoutees
in interface ClusterRouterActor
public scala.Option<scala.Tuple2<akka.actor.Address,java.lang.String>> selectDeploymentTarget()
public void removeMember(Member member)
removeMember
in interface ClusterRouterActor