akka.routing

Interface Pool

All Superinterfaces:

RouterConfig, java.io.Serializable

All Known Subinterfaces:

PoolOverrideUnsetConfig<T>

All Known Implementing Classes:

AdaptiveLoadBalancingPool, AdaptiveLoadBalancingPool, BalancingPool, BroadcastPool, ClusterRouterPool, ConsistentHashingPool, FromConfig, FromConfig$, PoolBase, RandomPool, RemoteRouterConfig, RoundRobinPool, ScatterGatherFirstCompletedPool, SmallestMailboxPool, TailChoppingPool

public interface Pool
extends RouterConfig

RouterConfig for router actor that creates routees as child actors and removes them from the router if they terminate.

Method Summary

Modifier and Type	Method and Description
RouterActor	createRouterActor() INTERNAL API
Props	enrichWithPoolDispatcher(Props routeeProps, ActorContext context) INTERNAL API
Routee	newRoutee(Props routeeProps, ActorContext context) INTERNAL API
int	nrOfInstances() Deprecated. Implement nrOfInstances with ActorSystem parameter instead. Since 2.4.
int	nrOfInstances(ActorSystem sys) Initial number of routee instances
Props	props(Props routeeProps) Props for a pool router based on the settings defined by this instance and the supplied Props for the routees created by the router.
scala.Option<Resizer>	resizer() Pool with dynamically resizable number of routees return the Resizer to use.
boolean	stopRouterWhenAllRouteesRemoved()
SupervisorStrategy	supervisorStrategy() SupervisorStrategy for the head actor, i.e.
boolean	usePoolDispatcher() Use a dedicated dispatcher for the routees of the pool.

Methods inherited from interface akka.routing.RouterConfig

createRouter, isManagementMessage, routerDispatcher, routingLogicController, verifyConfig, withFallback

Method Detail

nrOfInstances

int nrOfInstances()

Deprecated. Implement nrOfInstances with ActorSystem parameter instead. Since 2.4.

nrOfInstances

int nrOfInstances(ActorSystem sys)

Initial number of routee instances

Parameters:

sys - (undocumented)

Returns:

(undocumented)

usePoolDispatcher

boolean usePoolDispatcher()

Use a dedicated dispatcher for the routees of the pool. The dispatcher is defined in 'pool-dispatcher' configuration property in the deployment section of the router.

Returns:

(undocumented)

newRoutee

Routee newRoutee(Props routeeProps,
                 ActorContext context)

INTERNAL API

Parameters:

routeeProps - (undocumented)

context - (undocumented)

Returns:

(undocumented)

enrichWithPoolDispatcher

Props enrichWithPoolDispatcher(Props routeeProps,
                               ActorContext context)

INTERNAL API

Parameters:

routeeProps - (undocumented)

context - (undocumented)

Returns:

(undocumented)

resizer

scala.Option<Resizer> resizer()

Pool with dynamically resizable number of routees return the Resizer to use. The resizer is invoked once when the router is created, before any messages can be sent to it. Resize is also triggered when messages are sent to the routees, and the resizer is invoked asynchronously, i.e. not necessarily before the message has been sent.

Returns:

(undocumented)

supervisorStrategy

SupervisorStrategy supervisorStrategy()

SupervisorStrategy for the head actor, i.e. for supervising the routees of the pool.

Returns:

(undocumented)

props

Props props(Props routeeProps)

Props for a pool router based on the settings defined by this instance and the supplied Props for the routees created by the router.

Parameters:

routeeProps - (undocumented)

Returns:

(undocumented)

stopRouterWhenAllRouteesRemoved

boolean stopRouterWhenAllRouteesRemoved()

Specified by:

stopRouterWhenAllRouteesRemoved in interface RouterConfig

createRouterActor

RouterActor createRouterActor()

INTERNAL API

Specified by:

createRouterActor in interface RouterConfig

Returns:

(undocumented)