|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.routing.RouteeProvider
public class RouteeProvider
Factory and registry for routees of the router.
Uses context.actorOf
to create routees from nrOfInstances property
and context.actorFor
lookup routees from paths.
Constructor Summary | |
---|---|
RouteeProvider(ActorContext context,
Props routeeProps,
scala.Option<Resizer> resizer)
|
Method Summary | |
---|---|
ActorContext |
context()
|
void |
createRoutees(int nrOfInstances)
Creates new routees from specified Props and registers them. |
protected void |
delayedStop(Scheduler scheduler,
scala.collection.immutable.Iterable<ActorRef> abandon,
scala.concurrent.duration.FiniteDuration stopDelay)
Give concurrent messages a chance to be placed in mailbox before sending PoisonPill. |
java.util.List<ActorRef> |
getRoutees()
Java API: All routees of the router |
void |
registerRoutees(scala.collection.immutable.Iterable<ActorRef> routees)
Adds the routees to the router. |
void |
registerRoutees(java.lang.Iterable<ActorRef> routees)
Java API: Adds the routees to the router. |
void |
registerRouteesFor(scala.collection.immutable.Iterable<java.lang.String> paths)
Looks up routes with specified paths and registers them. |
void |
registerRouteesFor(java.lang.Iterable<java.lang.String> paths)
Java API: Looks up routes with specified paths and registers them. |
void |
removeRoutees(int nrOfInstances,
scala.concurrent.duration.FiniteDuration stopDelay)
Remove specified number of routees by unregister them and sending PoisonPill after the specified delay. |
scala.Option<Resizer> |
resizer()
|
Props |
routeeProps()
|
scala.collection.immutable.IndexedSeq<ActorRef> |
routees()
All routees of the router |
void |
unregisterRoutees(scala.collection.immutable.Iterable<ActorRef> routees)
Removes routees from the router. |
void |
unregisterRoutees(java.lang.Iterable<ActorRef> routees)
Java API: Removes routees from the router. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RouteeProvider(ActorContext context, Props routeeProps, scala.Option<Resizer> resizer)
Method Detail |
---|
public ActorContext context()
public Props routeeProps()
public scala.Option<Resizer> resizer()
public void registerRoutees(scala.collection.immutable.Iterable<ActorRef> routees)
RouterConfig.createRoute
and Resizer.resize
.
public void registerRoutees(java.lang.Iterable<ActorRef> routees)
RouterConfig.createRoute
and Resizer.resize
.
public void unregisterRoutees(scala.collection.immutable.Iterable<ActorRef> routees)
Resizer.resize
.
public void unregisterRoutees(java.lang.Iterable<ActorRef> routees)
Resizer.resize
.
public void registerRouteesFor(scala.collection.immutable.Iterable<java.lang.String> paths)
public void registerRouteesFor(java.lang.Iterable<java.lang.String> paths)
public void createRoutees(int nrOfInstances)
Props
and registers them.
public void removeRoutees(int nrOfInstances, scala.concurrent.duration.FiniteDuration stopDelay)
PoisonPill
after the specified delay.
The reason for the delay is to give concurrent messages a chance to be
placed in mailbox before sending PoisonPill.
protected void delayedStop(Scheduler scheduler, scala.collection.immutable.Iterable<ActorRef> abandon, scala.concurrent.duration.FiniteDuration stopDelay)
public scala.collection.immutable.IndexedSeq<ActorRef> routees()
public java.util.List<ActorRef> getRoutees()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |