akka.cluster.routing
Class ClusterRouterGroupActor
java.lang.Object
akka.routing.RouterActor
akka.cluster.routing.ClusterRouterGroupActor
- All Implemented Interfaces:
- Actor, ClusterRouterActor
public class ClusterRouterGroupActor
- extends RouterActor
- implements ClusterRouterActor
INTERNAL API
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.actor.Actor |
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preStart, self, sender, supervisorStrategy, unhandled |
ClusterRouterGroupActor
public ClusterRouterGroupActor(ClusterRouterGroupSettings settings)
settings
public ClusterRouterGroupSettings settings()
- Specified by:
settings
in interface ClusterRouterActor
group
public Group group()
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Overrides:
receive
in class RouterActor
- Returns:
- (undocumented)
usedRouteePaths
public scala.collection.immutable.Map<Address,scala.collection.immutable.Set<java.lang.String>> usedRouteePaths()
addRoutees
public void addRoutees()
- Adds routees based on totalInstances and maxInstancesPerNode settings
- Specified by:
addRoutees
in interface ClusterRouterActor
selectDeploymentTarget
public scala.Option<scala.Tuple2<Address,java.lang.String>> selectDeploymentTarget()
removeMember
public void removeMember(Member member)
- Specified by:
removeMember
in interface ClusterRouterActor