Class DurableProducerQueue

Inheritance
Object
DurableProducerQueue
Inherited Members
Namespace: Akka.Delivery
Assembly: Akka.dll
Syntax
public static class DurableProducerQueue

Fields

| Improve this Doc View Source

NoQualifier

Declaration
public const string NoQualifier = ""
Field Value
Type Description
String

Properties

| Improve this Doc View Source

Empty

Declaration
public static DurableProducerQueue.State<T> Empty { get; }
Property Value
Type Description
Akka.Delivery.DurableProducerQueue.State<T>

Methods

| Improve this Doc View Source

AddConfirmed(Int64, String, Int64)

Declaration
public DurableProducerQueue.State<T> AddConfirmed(long seqNr, string qualifier, long timestamp)
Parameters
Type Name Description
Int64 seqNr
String qualifier
Int64 timestamp
Returns
Type Description
Akka.Delivery.DurableProducerQueue.State<T>
| Improve this Doc View Source

AddMessageSent(MessageSent<T>)

Declaration
public DurableProducerQueue.State<T> AddMessageSent(MessageSent<T> messageSent)
Parameters
Type Name Description
MessageSent<T> messageSent
Returns
Type Description
Akka.Delivery.DurableProducerQueue.State<T>
| Improve this Doc View Source

CleanUp(ISet<String>)

Declaration
public DurableProducerQueue.State<T> CleanUp(ISet<string> confirmationQualifiers)
Parameters
Type Name Description
ISet<String> confirmationQualifiers
Returns
Type Description
Akka.Delivery.DurableProducerQueue.State<T>
| Improve this Doc 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
Akka.Delivery.DurableProducerQueue.State<T>
| Improve this Doc View Source

Equals(DurableProducerQueue.State<T>)

Declaration
public bool Equals(DurableProducerQueue.State<T> other)
Parameters
Type Name Description
Akka.Delivery.DurableProducerQueue.State<T> other
Returns
Type Description
Boolean
| Improve this Doc View Source

GetHashCode()

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