public interface Pool extends RouterConfig
RouterConfig
for router actor that creates routees as child actors and removes
them from the router if they terminate.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)
|
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.
|
createRouter, isManagementMessage, routerDispatcher, routingLogicController, verifyConfig, withFallback
int nrOfInstances()
int nrOfInstances(ActorSystem sys)
sys
- (undocumented)boolean usePoolDispatcher()
Routee newRoutee(Props routeeProps, ActorContext context)
routeeProps
- (undocumented)context
- (undocumented)Props enrichWithPoolDispatcher(Props routeeProps, ActorContext context)
routeeProps
- (undocumented)context
- (undocumented)scala.Option<Resizer> resizer()
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.SupervisorStrategy supervisorStrategy()
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.routeeProps
- (undocumented)boolean stopRouterWhenAllRouteesRemoved()
stopRouterWhenAllRouteesRemoved
in interface RouterConfig
RouterActor createRouterActor()
createRouterActor
in interface RouterConfig