Package org.apache.pekko.routing
package org.apache.pekko.routing
-
ClassDescription
Routeethat sends the messages to anpekko.actor.ActorRef.Routeethat sends the messages to anpekko.actor.ActorSelection.Add a routee by sending this message to the router.Increase or decrease the number of routees in aPool.A router pool that will try to redistribute work from busy routees to idle routees.INTERNAL API Can't be in theBalancingPoolcompanion for binary compatibility reasons.INTERNAL API Can't be in theBalancingPoolcompanion for binary compatibility reasons.INTERNAL APIUsed to broadcast a message to all routees in a router; only the contained message will be forwarded, i.e.A router group that broadcasts a message to all its routees.A router pool that broadcasts a message to all its routees.Broadcasts a message to all its routees.Consistent Hashing node ring implementation.A router group that uses consistent hashing to select a routee based on the sent message.A router pool that uses consistent hashing to select a routee based on the sent message.If you don't define thehashMappingwhen constructing thepekko.routing.ConsistentHashingRouterthe messages need to implement this interface to define what data to use for the consistent hash key.If you don't define thehashMappingwhen constructing thepekko.routing.ConsistentHashingRouterand messages can't implementpekko.routing.ConsistentHashingRouter.ConsistentHashablethemselves they can we wrapped by this envelope instead.JAVA API Mapping from message to the data to use for the consistent hash key.This resizer resizes the pool to an optimal size that provides the most message throughput.Java API: Wraps apekko.actor.Propsto mark the actor as externally configurable to be used with a router.Wraps apekko.actor.Propsto mark the actor as externally configurable to be used with a router.Sending this message to a router will make it send back its currently used routees.RouterConfigfor router actor with routee actors that are created external to the router and the router sends messages to the specified path using actor selection, without watching for termination.Java API: Base class for custom routerGroupListeners is a generic trait to implement listening capability on an Actor.An object designed to generate well-distributed non-cryptographic hashes.An object designed to generate well-distributed non-cryptographic hashes.Routeethat doesn't send the message to any routee.Routeethat doesn't send the message to any routee.Routing configuration that indicates no routing; this is also the default value which hence overrides the merge strategy in order to accept values from lower-precedence sources.INTERNAL APIINTERNAL APIRouterConfigfor router actor that creates routees as child actors and removes them from the router if they terminate.Java API: Base class for custom routerPoolPoolOverrideUnsetConfig<T extends Pool>INTERNAL APIA router group that randomly selects one of the target routees to send a message to.A router pool that randomly selects one of the target routees to send a message to.Randomly selects one of the target routees to send a message toRemove a specific routee by sending this message to the router.INTERNAL APIPoolrouters with dynamically resizable number of routees are implemented by providing a Resizer implementation in thepekko.routing.Poolconfiguration.A router group that uses round-robin to select a routee.A router pool that uses round-robin to select a routee.Uses round-robin to select a routee.INTERNAL APIAbstraction of a destination for messages routed via aRouter.Message used to carry information about what routees the router is currently using.For each message that is sent through the router via theRouter.route(java.lang.Object, org.apache.pekko.actor.ActorRef)method theRoutingLogicdecides to whichRouteeto send the message.This trait represents a router factory: it produces the actual router actor and creates the routing table (a function which determines the recipients for each message which is to be dispatched).Only the contained message will be forwarded to the destination, i.e.INTERNAL APIThe interface of the routing logic that is used in aRouterto select destination routed messages.A router group that broadcasts the message to all routees, and replies with the first response.A router pool that broadcasts the message to all routees, and replies with the first response.Broadcasts the message to all routees, and replies with the first response.Routeethat sends each message to allroutees.A router pool that tries to send to the non-suspended routee with fewest messages in mailbox.Tries to send to the non-suspended routee with fewest messages in mailbox.A router group with retry logic, intended for cases where a return message is expected in response to a message sent to the routee.A router pool with retry logic, intended for cases where a return message is expected in response to a message sent to the routee.As each message is sent to the router, the routees are randomly ordered.