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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidrouteesUpdated(scala.collection.immutable.Set<ActorRef<T>> newRoutees)Invoked an initial time beforeselectRouteeis ever called and then every time the set of available routees changes.ActorRef<T>selectRoutee(T msg)
-
-
-
Method Detail
-
routeesUpdated
void routeesUpdated(scala.collection.immutable.Set<ActorRef<T>> newRoutees)
Invoked an initial time beforeselectRouteeis 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 caseselectRoutee()will not be called beforerouteesUpdatedis invoked again with at least one routee. For a pool the pool stops instead of ever callingrouteesUpdatedwith an empty list of routees.
-
-