Class RoutingLogics.RandomLogic<T>
- java.lang.Object
-
- akka.actor.typed.internal.routing.RoutingLogics.RandomLogic<T>
-
- All Implemented Interfaces:
RoutingLogic<T>
- Enclosing class:
- RoutingLogics
public static final class RoutingLogics.RandomLogic<T> extends java.lang.Object implements RoutingLogic<T>
-
-
Constructor Summary
Constructors Constructor Description RandomLogic()
-
Method Summary
All Methods Instance Methods Concrete 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
public void routeesUpdated(scala.collection.immutable.Set<ActorRef<T>> newRoutees)
Description copied from interface:RoutingLogic
Invoked an initial time beforeselectRoutee
is ever called and then every time the set of available routees changes.- Specified by:
routeesUpdated
in interfaceRoutingLogic<T>
- 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.
-
selectRoutee
public ActorRef<T> selectRoutee(T msg)
- Specified by:
selectRoutee
in interfaceRoutingLogic<T>
-
-