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 void
routeesUpdated(scala.collection.immutable.Set<ActorRef<T>> newRoutees)
Invoked an initial time beforeselectRoutee
is 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 beforeselectRoutee
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 caseselectRoutee()
will not be called beforerouteesUpdated
is invoked again with at least one routee. For a pool the pool stops instead of ever callingrouteesUpdated
with an empty list of routees.
-
-