public final class ClusterRouterGroup extends java.lang.Object implements akka.routing.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(akka.routing.Group local,
ClusterRouterGroupSettings settings) |
Modifier and Type | Method and Description |
---|---|
akka.routing.RouterActor |
createRouterActor()
INTERNAL API
|
akka.routing.Group |
local() |
scala.collection.immutable.Iterable<java.lang.String> |
paths(akka.actor.ActorSystem system) |
ClusterRouterGroupSettings |
settings() |
akka.routing.RouterConfig |
withFallback(akka.routing.RouterConfig other) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createRouter, isManagementMessage, routerDispatcher, routingLogicController, stopRouterWhenAllRouteesRemoved
public ClusterRouterGroup(akka.routing.Group local, ClusterRouterGroupSettings settings)
public akka.routing.Group local()
local
in interface ClusterRouterConfigBase
public ClusterRouterGroupSettings settings()
settings
in interface ClusterRouterConfigBase
public scala.collection.immutable.Iterable<java.lang.String> paths(akka.actor.ActorSystem system)
paths
in interface akka.routing.Group
public akka.routing.RouterActor createRouterActor()
createRouterActor
in interface akka.routing.Group
createRouterActor
in interface akka.routing.RouterConfig
public akka.routing.RouterConfig withFallback(akka.routing.RouterConfig other)
withFallback
in interface akka.routing.RouterConfig