Package org.apache.pekko.actor.typed.internal.routing

Interface RoutingLogic<T>

All Known Implementing Classes:
RoutingLogics.ConsistentHashingLogic, RoutingLogics.RandomLogic, RoutingLogics.RoundRobinLogic
public interface RoutingLogic<T>
Kept in the behavior, not shared between instances, meant to be stateful.

INTERNAL API

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    routeesUpdated(scala.collection.immutable.Set<ActorRef<T>> newRoutees)
    Invoked an initial time before selectRoutee is ever called and then every time the set of available routees changes.
    ActorRef<T>
    selectRoutee(T msg)
     

  • Method Details

    • routeesUpdated

      void routeesUpdated(scala.collection.immutable.Set<ActorRef<T>> newRoutees)
      Invoked an initial time before selectRoutee is ever called and then every time the set of available routees changes.

      Parameters:
      newRoutees - The updated set of routees. For a group router this could be empty, in that case selectRoutee() will not be called before routeesUpdated is invoked again with at least one routee. For a pool the pool stops instead of ever calling routeesUpdated with an empty list of routees.

    • selectRoutee

      ActorRef<T> selectRoutee(T msg)