public final class ClusterRouterGroup extends java.lang.Object implements Group, 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 |
---|
ClusterRouterGroup(Group local,
ClusterRouterGroupSettings settings) |
Modifier and Type | Method and Description |
---|---|
abstract static boolean |
canEqual(java.lang.Object that) |
static Router |
createRouter(ActorSystem system) |
RouterActor |
createRouterActor()
INTERNAL API
|
abstract static boolean |
equals(java.lang.Object that) |
static boolean |
isManagementMessage(java.lang.Object msg) |
Group |
local() |
scala.collection.immutable.Iterable<java.lang.String> |
paths(ActorSystem system) |
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() |
static Routee |
routeeFor(java.lang.String path,
ActorContext context) |
static java.lang.String |
routerDispatcher() |
static scala.Option<Props> |
routingLogicController(RoutingLogic routingLogic) |
ClusterRouterGroupSettings |
settings() |
static boolean |
stopRouterWhenAllRouteesRemoved() |
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
createRouter, isManagementMessage, routerDispatcher, routingLogicController, stopRouterWhenAllRouteesRemoved
verifyConfig
public ClusterRouterGroup(Group local, ClusterRouterGroupSettings settings)
public static void verifyConfig(ActorPath path)
public static Props props()
public static Routee routeeFor(java.lang.String path, ActorContext context)
public static Router createRouter(ActorSystem system)
public static java.lang.String routerDispatcher()
public static boolean stopRouterWhenAllRouteesRemoved()
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 Group local()
local
in interface ClusterRouterConfigBase
public ClusterRouterGroupSettings settings()
settings
in interface ClusterRouterConfigBase
public scala.collection.immutable.Iterable<java.lang.String> paths(ActorSystem system)
public RouterActor createRouterActor()
createRouterActor
in interface Group
createRouterActor
in interface RouterConfig
public RouterConfig withFallback(RouterConfig other)
RouterConfig
this
(i.e. no merge).withFallback
in interface RouterConfig
other
- (undocumented)