SmallestMailboxRoutingLogic

org.apache.pekko.routing.SmallestMailboxRoutingLogic
See theSmallestMailboxRoutingLogic companion object

Tries to send to the non-suspended routee with fewest messages in mailbox. The selection is done in this order:

  • pick any idle routee (not processing message) with empty mailbox

  • pick any routee with empty mailbox

  • pick routee with fewest pending messages in mailbox

  • pick any remote routee, remote actors are consider lowest priority, since their mailbox size is unknown

Attributes

Companion
object
Source
SmallestMailbox.scala
Graph
Supertypes
trait RoutingLogic
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def select(message: Any, routees: IndexedSeq[Routee]): Routee

Pick the destination for a given message. Normally it picks one of the passed routees, but in the end it is up to the implementation to return whatever pekko.routing.Routee to use for sending a specific message.

Pick the destination for a given message. Normally it picks one of the passed routees, but in the end it is up to the implementation to return whatever pekko.routing.Routee to use for sending a specific message.

When implemented from Java it can be good to know that routees.apply(index) can be used to get an element from the IndexedSeq.

Attributes

Definition Classes
Source
SmallestMailbox.scala