akka.remote.routing
Class RemoteRouterConfig
java.lang.Object
akka.remote.routing.RemoteRouterConfig
- All Implemented Interfaces:
- akka.routing.Pool, akka.routing.RouterConfig, java.io.Serializable, scala.Equals, scala.Product
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
RoundRobinRouter or custom routers.
- See Also:
- Serialized Form
| Fields inherited from interface akka.routing.RouterConfig |
serialVersionUID |
|
Constructor Summary |
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)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Methods inherited from interface akka.routing.Pool |
enrichWithPoolDispatcher, props, stopRouterWhenAllRouteesRemoved, usePoolDispatcher |
| Methods inherited from interface akka.routing.RouterConfig |
isManagementMessage, routingLogicController, verifyConfig |
| Methods inherited from interface scala.Product |
productArity, productElement, productIterator, productPrefix |
| Methods inherited from interface scala.Equals |
canEqual, equals |
RemoteRouterConfig
public RemoteRouterConfig(akka.routing.Pool local,
scala.collection.Iterable<akka.actor.Address> nodes)
RemoteRouterConfig
public RemoteRouterConfig(akka.routing.Pool local,
java.lang.Iterable<akka.actor.Address> nodes)
RemoteRouterConfig
public RemoteRouterConfig(akka.routing.Pool local,
akka.actor.Address[] nodes)
local
public akka.routing.Pool local()
nodes
public scala.collection.Iterable<akka.actor.Address> nodes()
createRouter
public akka.routing.Router createRouter(akka.actor.ActorSystem system)
- Specified by:
createRouter in interface akka.routing.RouterConfig
nrOfInstances
public int nrOfInstances()
- Specified by:
nrOfInstances in interface akka.routing.Pool
newRoutee
public akka.routing.Routee newRoutee(akka.actor.Props routeeProps,
akka.actor.ActorContext context)
- Specified by:
newRoutee in interface akka.routing.Pool
createRouterActor
public akka.routing.RouterActor createRouterActor()
- Specified by:
createRouterActor in interface akka.routing.Pool- Specified by:
createRouterActor in interface akka.routing.RouterConfig
supervisorStrategy
public akka.actor.SupervisorStrategy supervisorStrategy()
- Specified by:
supervisorStrategy in interface akka.routing.Pool
routerDispatcher
public java.lang.String routerDispatcher()
- Specified by:
routerDispatcher in interface akka.routing.RouterConfig
resizer
public scala.Option<akka.routing.Resizer> resizer()
- Specified by:
resizer in interface akka.routing.Pool
withFallback
public akka.routing.RouterConfig withFallback(akka.routing.RouterConfig other)
- Specified by:
withFallback in interface akka.routing.RouterConfig