Package 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
Adds routees based on totalInstances and maxInstancesPerNode settings
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description ClusterRouterGroupActor(ClusterRouterGroupSettings settings)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addRoutees()
Adds routees based on totalInstances and maxInstancesPerNode settingsGroup
group()
scala.collection.immutable.SortedSet<Address>
nodes()
void
nodes_$eq(scala.collection.immutable.SortedSet<Address> x$1)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.void
removeMember(Member member)
scala.Option<scala.Tuple2<Address,java.lang.String>>
selectDeploymentTarget()
ClusterRouterGroupSettings
settings()
scala.collection.immutable.Map<Address,scala.collection.immutable.Set<java.lang.String>>
usedRouteePaths()
void
usedRouteePaths_$eq(scala.collection.immutable.Map<Address,scala.collection.immutable.Set<java.lang.String>> x$1)
-
Methods inherited from class akka.routing.RouterActor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, cell, context, preRestart, routingLogicController, self, stopIfAllRouteesRemoved
-
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, postRestart, postStop, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.cluster.routing.ClusterRouterActor
addMember, availableNodes, cluster, clusterReceive, fullAddress, isAvailable, postStop, preStart, satisfiesRoles
-
-
-
-
Constructor Detail
-
ClusterRouterGroupActor
public ClusterRouterGroupActor(ClusterRouterGroupSettings settings)
-
-
Method Detail
-
addRoutees
public void addRoutees()
Adds routees based on totalInstances and maxInstancesPerNode settings- Specified by:
addRoutees
in interfaceClusterRouterActor
-
group
public Group group()
-
nodes
public scala.collection.immutable.SortedSet<Address> nodes()
- Specified by:
nodes
in interfaceClusterRouterActor
-
nodes_$eq
public void nodes_$eq(scala.collection.immutable.SortedSet<Address> x$1)
- Specified by:
nodes_$eq
in interfaceClusterRouterActor
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.- Specified by:
receive
in interfaceActor
- Overrides:
receive
in classRouterActor
- Returns:
- (undocumented)
-
removeMember
public void removeMember(Member member)
- Specified by:
removeMember
in interfaceClusterRouterActor
-
selectDeploymentTarget
public scala.Option<scala.Tuple2<Address,java.lang.String>> selectDeploymentTarget()
-
settings
public ClusterRouterGroupSettings settings()
- Specified by:
settings
in interfaceClusterRouterActor
-
usedRouteePaths
public scala.collection.immutable.Map<Address,scala.collection.immutable.Set<java.lang.String>> usedRouteePaths()
-
usedRouteePaths_$eq
public void usedRouteePaths_$eq(scala.collection.immutable.Map<Address,scala.collection.immutable.Set<java.lang.String>> x$1)
-
-