public final class ScatterGatherFirstCompletedGroup extends java.lang.Object implements Group, scala.Product, scala.Serializable
The configuration parameter trumps the constructor arguments. This means that
if you provide paths
during instantiation they will be ignored if
the router is defined in the configuration file for the actor being used.
param: paths string representation of the actor paths of the routees, messages are
sent with ActorSelection
to these paths
param: within expecting at least one reply within this duration, otherwise
it will reply with AskTimeoutException
in a Status.Failure
param: routerDispatcher dispatcher to use for the router head actor, which handles router management messages
Constructor and Description |
---|
ScatterGatherFirstCompletedGroup(com.typesafe.config.Config config) |
ScatterGatherFirstCompletedGroup(java.lang.Iterable<java.lang.String> routeePaths,
scala.concurrent.duration.FiniteDuration within)
Java API
|
ScatterGatherFirstCompletedGroup(scala.collection.immutable.Iterable<java.lang.String> paths,
scala.concurrent.duration.FiniteDuration within,
java.lang.String routerDispatcher) |
Modifier and Type | Method and Description |
---|---|
Router |
createRouter(ActorSystem system)
Create the actual router, responsible for routing messages to routees.
|
scala.collection.immutable.Iterable<java.lang.String> |
paths() |
scala.collection.immutable.Iterable<java.lang.String> |
paths(ActorSystem system) |
java.lang.String |
routerDispatcher()
Dispatcher ID to use for running the “head” actor, which handles
supervision, death watch and router management messages
|
ScatterGatherFirstCompletedGroup |
withDispatcher(java.lang.String dispatcherId)
Setting the dispatcher to be used for the router head actor, which handles
router management messages
|
scala.concurrent.duration.FiniteDuration |
within() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createRouterActor, props, routeeFor
isManagementMessage, routingLogicController, stopRouterWhenAllRouteesRemoved, verifyConfig, withFallback
public ScatterGatherFirstCompletedGroup(scala.collection.immutable.Iterable<java.lang.String> paths, scala.concurrent.duration.FiniteDuration within, java.lang.String routerDispatcher)
public ScatterGatherFirstCompletedGroup(com.typesafe.config.Config config)
public ScatterGatherFirstCompletedGroup(java.lang.Iterable<java.lang.String> routeePaths, scala.concurrent.duration.FiniteDuration within)
routeePaths
- string representation of the actor paths of the routees, messages are
sent with ActorSelection
to these pathswithin
- expecting at least one reply within this duration, otherwise
it will reply with AskTimeoutException
in a Status.Failure
public scala.collection.immutable.Iterable<java.lang.String> paths()
public scala.concurrent.duration.FiniteDuration within()
public java.lang.String routerDispatcher()
RouterConfig
routerDispatcher
in interface RouterConfig
public scala.collection.immutable.Iterable<java.lang.String> paths(ActorSystem system)
public Router createRouter(ActorSystem system)
RouterConfig
createRouter
in interface RouterConfig
system
- the ActorSystem this router belongs topublic ScatterGatherFirstCompletedGroup withDispatcher(java.lang.String dispatcherId)
dispatcherId
- (undocumented)