Search Results for

    Show / Hide Table of Contents

    Class ScatterGatherFirstCompletedRoutingLogic

    This class contains logic used by a Router to route a message to a Routee determined using scatter-gather-first-completed. This process has the router send a message to all of its routees. The first response is used and the remaining are discarded. If the none of the routees respond within a specified time limit, a timeout failure occurs.

    Inheritance
    object
    RoutingLogic
    ScatterGatherFirstCompletedRoutingLogic
    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 ScatterGatherFirstCompletedRoutingLogic : RoutingLogic, INoSerializationVerificationNeeded

    Constructors

    | Edit this page View Source

    ScatterGatherFirstCompletedRoutingLogic(TimeSpan)

    Initializes a new instance of the ScatterGatherFirstCompletedRoutingLogic class.

    Declaration
    public ScatterGatherFirstCompletedRoutingLogic(TimeSpan within)
    Parameters
    Type Name Description
    TimeSpan within

    The amount of time to wait for a response.

    Methods

    | Edit this page View Source

    Select(object, Routee[])

    Picks all the provided routees 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 Akka.Routing.ScatterGatherFirstCompletedRoutees 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