akka.cluster.routing

Class ClusterRouterPoolActor

java.lang.Object

akka.routing.RouterActor

akka.routing.RouterPoolActor

akka.cluster.routing.ClusterRouterPoolActor

All Implemented Interfaces:

Actor, ClusterRouterActor

public class ClusterRouterPoolActor
extends RouterPoolActor
implements ClusterRouterActor

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
ClusterRouterPoolActor(SupervisorStrategy supervisorStrategy, ClusterRouterPoolSettings settings)

Method Summary

Modifier and Type	Method and Description
void	addRoutees() Adds routees based on totalInstances and maxInstancesPerNode settings
scala.collection.immutable.SortedSet<Address>	nodes()
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.
scala.Option<Address>	selectDeploymentTarget()
ClusterRouterPoolSettings	settings()

Methods inherited from class akka.routing.RouterPoolActor

pool, supervisorStrategy

Methods inherited from class akka.routing.RouterActor

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.cluster.routing.ClusterRouterActor

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

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preStart, sender, unhandled

Constructor Detail

ClusterRouterPoolActor

public ClusterRouterPoolActor(SupervisorStrategy supervisorStrategy,
                              ClusterRouterPoolSettings settings)

Method Detail

nodes

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

Specified by:

nodes in interface ClusterRouterActor

settings

public ClusterRouterPoolSettings settings()

Specified by:

settings in interface ClusterRouterActor

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 RouterPoolActor

Returns:

(undocumented)

addRoutees

public void addRoutees()

Adds routees based on totalInstances and maxInstancesPerNode settings

Specified by:

addRoutees in interface ClusterRouterActor

selectDeploymentTarget

public scala.Option<Address> selectDeploymentTarget()