Table of Contents

Class InMemoryDeadLetterStore<TPayload>

Namespace
PatternKit.Messaging.Reliability
Assembly
PatternKit.Core.dll

In-memory dead-letter store suitable for tests, samples, and embedded applications.

public sealed class InMemoryDeadLetterStore<TPayload> : IDeadLetterStore<TPayload>

Type Parameters

TPayload
Inheritance
InMemoryDeadLetterStore<TPayload>
Implements
Inherited Members

Properties

Messages

Captured dead-letter messages.

public IReadOnlyList<DeadLetterMessage<TPayload>> Messages { get; }

Property Value

IReadOnlyList<DeadLetterMessage<TPayload>>

Methods

EnqueueAsync(DeadLetterMessage<TPayload>, CancellationToken)

Persists a dead-letter message.

public ValueTask EnqueueAsync(DeadLetterMessage<TPayload> message, CancellationToken cancellationToken = default)

Parameters

message DeadLetterMessage<TPayload>
cancellationToken CancellationToken

Returns

ValueTask

TryLoadAsync(string, CancellationToken)

Attempts to load a dead-letter message by id.

public ValueTask<DeadLetterMessage<TPayload>?> TryLoadAsync(string id, CancellationToken cancellationToken = default)

Parameters

id string
cancellationToken CancellationToken

Returns

ValueTask<DeadLetterMessage<TPayload>>