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

INTERNAL API

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

Modifier and Type	Method	Description
void	addRoutees()	Adds routees based on totalInstances and maxInstancesPerNode settings
Group	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 interface ClusterRouterActor

group

public Group group()

nodes

public scala.collection.immutable.SortedSet<Address> nodes()

Specified by:

nodes in interface ClusterRouterActor

nodes_$eq

public void nodes_$eq(scala.collection.immutable.SortedSet<Address> x$1)

Specified by:

nodes_$eq in interface ClusterRouterActor

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 interface Actor

Overrides:

receive in class RouterActor

removeMember

public void removeMember(Member member)

Specified by:

removeMember in interface ClusterRouterActor

selectDeploymentTarget

public scala.Option<scala.Tuple2<Address,java.lang.String>> selectDeploymentTarget()

settings

public ClusterRouterGroupSettings settings()

Specified by:

settings in interface ClusterRouterActor

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)