public final class ClusterRouterPool extends java.lang.Object implements 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(Pool local,
ClusterRouterPoolSettings settings) |
Modifier and Type | Method and Description |
---|---|
abstract static boolean |
canEqual(java.lang.Object that) |
static Router |
createRouter(ActorSystem system) |
RouterActor |
createRouterActor()
INTERNAL API
|
static Props |
enrichWithPoolDispatcher(Props routeeProps,
ActorContext context) |
abstract static boolean |
equals(java.lang.Object that) |
static boolean |
isManagementMessage(java.lang.Object msg) |
Pool |
local() |
Routee |
newRoutee(Props routeeProps,
ActorContext context)
INTERNAL API
|
int |
nrOfInstances(ActorSystem sys)
Initial number of routee instances
|
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
static Props |
props(Props routeeProps) |
scala.Option<Resizer> |
resizer()
Pool with dynamically resizable number of routees return the
Resizer
to use. |
static java.lang.String |
routerDispatcher() |
static scala.Option<Props> |
routingLogicController(RoutingLogic routingLogic) |
ClusterRouterPoolSettings |
settings() |
static boolean |
stopRouterWhenAllRouteesRemoved() |
SupervisorStrategy |
supervisorStrategy()
SupervisorStrategy for the head actor, i.e.
|
static boolean |
usePoolDispatcher() |
static void |
verifyConfig(ActorPath path) |
RouterConfig |
withFallback(RouterConfig other)
Overridable merge strategy, by default completely prefers
this (i.e. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
enrichWithPoolDispatcher, nrOfInstances, props, stopRouterWhenAllRouteesRemoved, usePoolDispatcher
createRouter, isManagementMessage, routerDispatcher, routingLogicController, stopRouterWhenAllRouteesRemoved
verifyConfig
public ClusterRouterPool(Pool local, ClusterRouterPoolSettings settings)
public static void verifyConfig(ActorPath path)
public static boolean usePoolDispatcher()
public static Props enrichWithPoolDispatcher(Props routeeProps, ActorContext context)
public static boolean stopRouterWhenAllRouteesRemoved()
public static Router createRouter(ActorSystem system)
public static java.lang.String routerDispatcher()
public static scala.Option<Props> routingLogicController(RoutingLogic routingLogic)
public static boolean isManagementMessage(java.lang.Object msg)
public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public Pool local()
local
in interface ClusterRouterConfigBase
public ClusterRouterPoolSettings settings()
settings
in interface ClusterRouterConfigBase
public Routee newRoutee(Props routeeProps, ActorContext context)
public int nrOfInstances(ActorSystem sys)
nrOfInstances
in interface Pool
sys
- (undocumented)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.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)