public final class ClusterRouterPool extends java.lang.Object implements akka.routing.Pool, ClusterRouterConfigBase, scala.Product, scala.Serializable
RouterConfig
implementation for deployment on cluster nodes.
Delegates other duties to the local RouterConfig
,
which makes it possible to mix this with the built-in routers such as
RoundRobinGroup
or custom routers.Constructor and Description |
---|
ClusterRouterPool(akka.routing.Pool local,
ClusterRouterPoolSettings settings) |
Modifier and Type | Method and Description |
---|---|
akka.routing.RouterActor |
createRouterActor()
INTERNAL API
|
akka.routing.Pool |
local() |
akka.routing.Routee |
newRoutee(akka.actor.Props routeeProps,
akka.actor.ActorContext context)
INTERNAL API
|
int |
nrOfInstances(akka.actor.ActorSystem sys)
Initial number of routee instances
|
scala.Option<akka.routing.Resizer> |
resizer() |
ClusterRouterPoolSettings |
settings() |
akka.actor.SupervisorStrategy |
supervisorStrategy() |
akka.routing.RouterConfig |
withFallback(akka.routing.RouterConfig other) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
enrichWithPoolDispatcher, nrOfInstances, props, stopRouterWhenAllRouteesRemoved, usePoolDispatcher
createRouter, isManagementMessage, routerDispatcher, routingLogicController, stopRouterWhenAllRouteesRemoved
public ClusterRouterPool(akka.routing.Pool local, ClusterRouterPoolSettings settings)
public akka.routing.Pool local()
local
in interface ClusterRouterConfigBase
public ClusterRouterPoolSettings settings()
settings
in interface ClusterRouterConfigBase
public akka.routing.Routee newRoutee(akka.actor.Props routeeProps, akka.actor.ActorContext context)
newRoutee
in interface akka.routing.Pool
routeeProps
- (undocumented)context
- (undocumented)public int nrOfInstances(akka.actor.ActorSystem sys)
nrOfInstances
in interface akka.routing.Pool
sys
- (undocumented)public scala.Option<akka.routing.Resizer> resizer()
resizer
in interface akka.routing.Pool
public akka.routing.RouterActor createRouterActor()
createRouterActor
in interface akka.routing.Pool
createRouterActor
in interface akka.routing.RouterConfig
public akka.actor.SupervisorStrategy supervisorStrategy()
supervisorStrategy
in interface akka.routing.Pool
public akka.routing.RouterConfig withFallback(akka.routing.RouterConfig other)
withFallback
in interface akka.routing.RouterConfig