Search Results for

    Show / Hide Table of Contents

    Class SmallestMailboxRoutingLogic

    This class contains logic used by a Router to route a message to a Routee determined using smallest-mailbox. This process has the router select a routee based on the fewest number of messages in its routees' mailbox. The selection is done in the following order:

    • Pick any routee with an empty mailbox.
    • Pick a routee with the fewest pending messages in its mailbox.
    • Pick any remaining routees.
    note

    Remote routees are consider lowest priority, since their mailbox size is unknown.

    note

    For the case, when all routees are of unpredictable size, the selection process fails back to round-robin.

    Inheritance
    object
    RoutingLogic
    SmallestMailboxRoutingLogic
    Implements
    INoSerializationVerificationNeeded
    Inherited Members
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Routing
    Assembly: Akka.dll
    Syntax
    public sealed class SmallestMailboxRoutingLogic : RoutingLogic, INoSerializationVerificationNeeded

    Constructors

    | Edit this page View Source

    SmallestMailboxRoutingLogic()

    Initializes a new instance of the SmallestMailboxRoutingLogic class.

    Declaration
    public SmallestMailboxRoutingLogic()
    | Edit this page View Source

    SmallestMailboxRoutingLogic(int)

    Initializes a new instance of the SmallestMailboxRoutingLogic class.

    Declaration
    public SmallestMailboxRoutingLogic(int next)
    Parameters
    Type Name Description
    int next

    Seed value used in the fallback selection process.

    Methods

    | Edit this page View Source

    Select(object, Routee[])

    Picks a Routee to receive the message.

    Declaration
    public override Routee Select(object message, Routee[] routees)
    Parameters
    Type Name Description
    object message

    The message that is being routed

    Routee[] routees

    A collection of routees to choose from when receiving the message.

    Returns
    Type Description
    Routee

    A Routee that receives the message.

    Overrides
    RoutingLogic.Select(object, Routee[])

    Implements

    INoSerializationVerificationNeeded

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET