akka.routing

RouteeProvider

class RouteeProvider extends AnyRef

Factory and registry for routees of the router. Uses context.actorOf to create routees from nrOfInstances property and context.actorFor lookup routees from paths.

Linear Supertypes
AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. RouteeProvider
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RouteeProvider(context: ActorContext, routeeProps: Props, resizer: Option[Resizer])

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  8. val context: ActorContext

  9. def createRoutees(nrOfInstances: Int): Unit

    Creates new routees from specified Props and registers them.

  10. def delayedStop(scheduler: Scheduler, abandon: Iterable[ActorRef], stopDelay: FiniteDuration): Unit

    Give concurrent messages a chance to be placed in mailbox before sending PoisonPill.

    Give concurrent messages a chance to be placed in mailbox before sending PoisonPill.

    Attributes
    protected
  11. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  14. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  15. def getRoutees(): List[ActorRef]

    Java API: All routees of the router

  16. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  17. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  19. final def notify(): Unit

    Definition Classes
    AnyRef
  20. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  21. def registerRoutees(routees: Iterable[ActorRef]): Unit

    Java API: Adds the routees to the router.

    Java API: Adds the routees to the router. Adds death watch of the routees so that they are removed when terminated. Not thread safe, but intended to be called from protected points, such as RouterConfig.createRoute and Resizer.resize.

  22. def registerRoutees(routees: Iterable[ActorRef]): Unit

    Adds the routees to the router.

    Adds the routees to the router. Adds death watch of the routees so that they are removed when terminated. Not thread safe, but intended to be called from protected points, such as RouterConfig.createRoute and Resizer.resize.

  23. def registerRouteesFor(paths: Iterable[String]): Unit

    Java API: Looks up routes with specified paths and registers them.

  24. def registerRouteesFor(paths: Iterable[String]): Unit

    Looks up routes with specified paths and registers them.

  25. def removeRoutees(nrOfInstances: Int, stopDelay: FiniteDuration): Unit

    Remove specified number of routees by unregister them and sending akka.actor.PoisonPill after the specified delay.

    Remove specified number of routees by unregister them and sending akka.actor.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.

  26. val resizer: Option[Resizer]

  27. val routeeProps: Props

  28. def routees: IndexedSeq[ActorRef]

    All routees of the router

  29. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  30. def toString(): String

    Definition Classes
    AnyRef → Any
  31. def unregisterRoutees(routees: Iterable[ActorRef]): Unit

    Java API: Removes routees from the router.

    Java API: Removes routees from the router. This method doesn't stop the routees. Removes death watch of the routees. Not thread safe, but intended to be called from protected points, such as Resizer.resize.

  32. def unregisterRoutees(routees: Iterable[ActorRef]): Unit

    Removes routees from the router.

    Removes routees from the router. This method doesn't stop the routees. Removes death watch of the routees. Not thread safe, but intended to be called from protected points, such as Resizer.resize.

  33. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  34. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  35. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from AnyRef

Inherited from Any

Ungrouped