Search Results for

    Show / Hide Table of Contents

    Class ProducerController.RequestNext<T>

    A send instruction sent from the ProducerController to the Producer to request the next message to be sent.

    Inheritance
    object
    ProducerController.RequestNext<T>
    Implements
    ProducerController.IProducerCommand<T>
    INoSerializationVerificationNeeded
    Inherited Members
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Delivery
    Assembly: Akka.dll
    Syntax
    public sealed class ProducerController.RequestNext<T> : ProducerController.IProducerCommand<T>, INoSerializationVerificationNeeded
    Type Parameters
    Name Description
    T

    Constructors

    | Edit this page View Source

    RequestNext(string, long, long, IActorRef)

    Declaration
    public RequestNext(string producerId, long currentSeqNr, long confirmedSeqNr, IActorRef sendNextTo)
    Parameters
    Type Name Description
    string producerId
    long currentSeqNr
    long confirmedSeqNr
    IActorRef sendNextTo

    Properties

    | Edit this page View Source

    ConfirmedSeqNr

    The highest confirmed seqNr observed by the producer controller.

    Declaration
    public long ConfirmedSeqNr { get; }
    Property Value
    Type Description
    long
    | Edit this page View Source

    CurrentSeqNr

    The current seqNr being handled by the producer controller.

    Declaration
    public long CurrentSeqNr { get; }
    Property Value
    Type Description
    long
    | Edit this page View Source

    ProducerId

    The message that will actually be delivered to consumers.

    Declaration
    public string ProducerId { get; }
    Property Value
    Type Description
    string
    | Edit this page View Source

    SendNextTo

    If this field is populated, confirmation messages containing the current SeqNo (long) will be sent to this actor.

    Declaration
    public IActorRef SendNextTo { get; }
    Property Value
    Type Description
    IActorRef

    Methods

    | Edit this page View Source

    AskNextTo(MessageWithConfirmation<T>)

    Delivers a ProducerController.MessageWithConfirmation<T> to the SendNextTo actor.

    The ReplyTo actor will receive a confirmation message containing the confirmed SeqNo (long) for this message once it's been successfully processed by the consumer.

    Declaration
    public void AskNextTo(ProducerController.MessageWithConfirmation<T> msgWithConfirmation)
    Parameters
    Type Name Description
    ProducerController.MessageWithConfirmation<T> msgWithConfirmation

    The message and the replyTo address.

    Remarks

    This method name is a bit misleading - we're actually performing a Tell, not an Ask.

    The other overload does perform an Ask and uses the temporary Ask actor as the replyTo address.

    | Edit this page View Source

    AskNextTo(T, CancellationToken)

    Uses an Ask{T} to send the message to the SendNextTo actor and returns an Ack(long).

    Declaration
    public Task<long> AskNextTo(T msg, CancellationToken cancellationToken = default)
    Parameters
    Type Name Description
    T msg

    The message to send with confirmation back to the temporary Ask actor.

    CancellationToken cancellationToken

    Optional - a CancellationToken.

     Note: this token only cancels the receipt of the Ack (long) - it does not stop the message from being delivered.
    
    Returns
    Type Description
    Task<long>

    A task that will complete once the message has been successfully persisted by the ProducerController.

    Implements

    ProducerController.IProducerCommand<T>
    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