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$

Constructor Summary

ClusterRouterPoolActor(SupervisorStrategy supervisorStrategy, ClusterRouterPoolSettings settings)

Method Summary

void	addRoutees() Adds routees based on totalInstances and maxInstancesPerNode settings
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, 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, removeMember, satisfiesRole

Methods inherited from interface akka.actor.Actor

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

Constructor Detail

ClusterRouterPoolActor

public ClusterRouterPoolActor(SupervisorStrategy supervisorStrategy,
                              ClusterRouterPoolSettings settings)

Method Detail

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()