public final class RemoteRouterConfig
extends java.lang.Object
implements akka.routing.Pool, scala.Product, scala.Serializable
RouterConfig
implementation for remote deployment on defined
target nodes. Delegates other duties to the local Pool
,
which makes it possible to mix this with the built-in routers such as
RoundRobinGroup
or custom routers.Constructor and Description |
---|
RemoteRouterConfig(akka.routing.Pool local,
akka.actor.Address[] nodes) |
RemoteRouterConfig(akka.routing.Pool local,
scala.collection.Iterable<akka.actor.Address> nodes) |
RemoteRouterConfig(akka.routing.Pool local,
java.lang.Iterable<akka.actor.Address> nodes) |
Modifier and Type | Method and Description |
---|---|
akka.routing.Router |
createRouter(akka.actor.ActorSystem system) |
akka.routing.RouterActor |
createRouterActor() |
akka.routing.Pool |
local() |
akka.routing.Routee |
newRoutee(akka.actor.Props routeeProps,
akka.actor.ActorContext context) |
scala.collection.Iterable<akka.actor.Address> |
nodes() |
int |
nrOfInstances(akka.actor.ActorSystem sys) |
scala.Option<akka.routing.Resizer> |
resizer() |
java.lang.String |
routerDispatcher() |
akka.actor.SupervisorStrategy |
supervisorStrategy() |
akka.routing.RouterConfig |
withFallback(akka.routing.RouterConfig other) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
enrichWithPoolDispatcher, nrOfInstances, props, stopRouterWhenAllRouteesRemoved, usePoolDispatcher
isManagementMessage, routingLogicController, verifyConfig
public RemoteRouterConfig(akka.routing.Pool local, scala.collection.Iterable<akka.actor.Address> nodes)
public RemoteRouterConfig(akka.routing.Pool local, java.lang.Iterable<akka.actor.Address> nodes)
public RemoteRouterConfig(akka.routing.Pool local, akka.actor.Address[] nodes)
public akka.routing.Pool local()
public scala.collection.Iterable<akka.actor.Address> nodes()
public akka.routing.Router createRouter(akka.actor.ActorSystem system)
createRouter
in interface akka.routing.RouterConfig
public int nrOfInstances(akka.actor.ActorSystem sys)
nrOfInstances
in interface akka.routing.Pool
public akka.routing.Routee newRoutee(akka.actor.Props routeeProps, akka.actor.ActorContext context)
newRoutee
in interface akka.routing.Pool
public akka.routing.RouterActor createRouterActor()
createRouterActor
in interface akka.routing.Pool
createRouterActor
in interface akka.routing.RouterConfig
public akka.actor.SupervisorStrategy supervisorStrategy()
supervisorStrategy
in interface akka.routing.Pool
public java.lang.String routerDispatcher()
routerDispatcher
in interface akka.routing.RouterConfig
public scala.Option<akka.routing.Resizer> resizer()
resizer
in interface akka.routing.Pool
public akka.routing.RouterConfig withFallback(akka.routing.RouterConfig other)
withFallback
in interface akka.routing.RouterConfig