|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.cluster.routing.ClusterRouterPool
public final class ClusterRouterPool
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
RoundRobinRouter
or custom routers.
Constructor Summary | |
---|---|
ClusterRouterPool(Pool local,
ClusterRouterPoolSettings settings)
|
Method Summary | |
---|---|
RouterActor |
createRouterActor()
INTERNAL API |
Pool |
local()
|
Routee |
newRoutee(Props routeeProps,
ActorContext context)
INTERNAL API |
int |
nrOfInstances()
Initial number of routee instances |
scala.Option<Resizer> |
resizer()
Pool with dynamically resizable number of routees return the Resizer
to use. |
ClusterRouterPoolSettings |
settings()
|
SupervisorStrategy |
supervisorStrategy()
SupervisorStrategy for the head actor, i.e. |
RouterConfig |
withFallback(RouterConfig other)
Overridable merge strategy, by default completely prefers this (i.e. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.routing.Pool |
---|
enrichWithPoolDispatcher, props, stopRouterWhenAllRouteesRemoved, usePoolDispatcher |
Methods inherited from interface akka.cluster.routing.ClusterRouterConfigBase |
---|
createRouter, isManagementMessage, routerDispatcher, routingLogicController, stopRouterWhenAllRouteesRemoved |
Methods inherited from interface akka.routing.RouterConfig |
---|
verifyConfig |
Methods inherited from interface scala.Product |
---|
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
---|
canEqual, equals |
Constructor Detail |
---|
public ClusterRouterPool(Pool local, ClusterRouterPoolSettings settings)
Method Detail |
---|
public Pool local()
local
in interface ClusterRouterConfigBase
public ClusterRouterPoolSettings settings()
settings
in interface ClusterRouterConfigBase
public Routee newRoutee(Props routeeProps, ActorContext context)
newRoutee
in interface Pool
routeeProps
- (undocumented)context
- (undocumented)
public int nrOfInstances()
nrOfInstances
in interface Pool
public scala.Option<Resizer> resizer()
Pool
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.
resizer
in interface Pool
public RouterActor createRouterActor()
createRouterActor
in interface Pool
createRouterActor
in interface RouterConfig
public SupervisorStrategy supervisorStrategy()
Pool
supervisorStrategy
in interface Pool
public RouterConfig withFallback(RouterConfig other)
RouterConfig
this
(i.e. no merge).
withFallback
in interface RouterConfig
other
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |