Struct DurableProducerQueue.State<T>

Durable producer queue state

Implements
Inherited Members
Namespace: Akka.Delivery
Assembly: Akka.dll
Syntax
public readonly record struct DurableProducerQueue.State<T> : IEquatable<DurableProducerQueue.State<T>>
Type Parameters
Name Description
T

Constructors

| Edit this page View Source

State(long, long, ImmutableDictionary<string, (long, long)>, ImmutableList<MessageSent<T>>)

Durable producer queue state

Declaration
public State(long CurrentSeqNr, long HighestConfirmedSeqNr, ImmutableDictionary<string, (long, long)> ConfirmedSeqNr, ImmutableList<DurableProducerQueue.MessageSent<T>> Unconfirmed)
Parameters
Type Name Description
long CurrentSeqNr
long HighestConfirmedSeqNr
ImmutableDictionary<string, (long, long)> ConfirmedSeqNr
ImmutableList<DurableProducerQueue.MessageSent<T>> Unconfirmed

Properties

| Edit this page View Source

ConfirmedSeqNr

Declaration
public ImmutableDictionary<string, (long, long)> ConfirmedSeqNr { get; init; }
Property Value
Type Description
ImmutableDictionary<string, (long, long)>
| Edit this page View Source

CurrentSeqNr

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

Empty

Declaration
public static DurableProducerQueue.State<T> Empty { get; }
Property Value
Type Description
DurableProducerQueue.State<T>
| Edit this page View Source

HighestConfirmedSeqNr

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

Unconfirmed

Declaration
public ImmutableList<DurableProducerQueue.MessageSent<T>> Unconfirmed { get; init; }
Property Value
Type Description
ImmutableList<DurableProducerQueue.MessageSent<T>>

Methods

| Edit this page View Source

AddConfirmed(long, string, long)

Declaration
public DurableProducerQueue.State<T> AddConfirmed(long seqNr, string qualifier, long timestamp)
Parameters
Type Name Description
long seqNr
string qualifier
long timestamp
Returns
Type Description
DurableProducerQueue.State<T>
| Edit this page View Source

AddMessageSent(MessageSent<T>)

Declaration
public DurableProducerQueue.State<T> AddMessageSent(DurableProducerQueue.MessageSent<T> messageSent)
Parameters
Type Name Description
DurableProducerQueue.MessageSent<T> messageSent
Returns
Type Description
DurableProducerQueue.State<T>
| Edit this page View Source

CleanUp(ISet<string>)

Declaration
public DurableProducerQueue.State<T> CleanUp(ISet<string> confirmationQualifiers)
Parameters
Type Name Description
ISet<string> confirmationQualifiers
Returns
Type Description
DurableProducerQueue.State<T>
| Edit this page View Source

CleanUpPartialChunkedMessages()

If not all chunked messages were stored before crash, those partial messages should not be resent.

Declaration
public DurableProducerQueue.State<T> CleanUpPartialChunkedMessages()
Returns
Type Description
DurableProducerQueue.State<T>
| Edit this page View Source

Equals(State<T>)

Declaration
public bool Equals(DurableProducerQueue.State<T> other)
Parameters
Type Name Description
DurableProducerQueue.State<T> other
Returns
Type Description
bool
| Edit this page View Source

GetHashCode()

Declaration
public override int GetHashCode()
Returns
Type Description
int
Overrides

Implements

Extension Methods