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
Inherited Members
Namespace: Akka.Delivery
Assembly: Akka.dll
Syntax
public sealed class RequestNext<T> : ProducerController.IProducerCommand<T>, INoSerializationVerificationNeeded
Type Parameters
Name Description
T

Constructors

| Improve this Doc View Source

RequestNext(String, Int64, Int64, IActorRef)

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

Properties

| Improve this Doc View Source

ConfirmedSeqNr

The highest confirmed seqNr observed by the producer controller.

Declaration
public long ConfirmedSeqNr { get; }
Property Value
Type Description
Int64
| Improve this Doc View Source

CurrentSeqNr

The current seqNr being handled by the producer controller.

Declaration
public long CurrentSeqNr { get; }
Property Value
Type Description
Int64
| Improve this Doc View Source

ProducerId

The message that will actually be delivered to consumers.

Declaration
public string ProducerId { get; }
Property Value
Type Description
String
| Improve this Doc 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

| Improve this Doc 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(CancellationToken))
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<Int64>

A task that will complete once the message has been successfully persisted by the ProducerController.
| Improve this Doc View Source

AskNextTo(ProducerController.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.

Implements

Extension Methods