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$

Constructor Summary

ClusterRouterGroupActor(ClusterRouterGroupSettings settings)

Method Summary

void	addRoutees() Adds routees based on totalInstances and maxInstancesPerNode settings
Group	group()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive() 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()

Methods inherited from class akka.routing.RouterActor

cell, preRestart, routingLogicController, stopIfAllRouteesRemoved

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.cluster.routing.ClusterRouterActor

addMember, availableNodes, cluster, clusterReceive, fullAddress, isAvailable, nodes, postStop, preStart, satisfiesRole

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preStart, self, sender, supervisorStrategy, unhandled

Constructor Detail

ClusterRouterGroupActor

public ClusterRouterGroupActor(ClusterRouterGroupSettings settings)

Method Detail

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