Interface IDeadLetterStore<TPayload>

Namespace

PatternKit.Messaging.Reliability

Assembly

PatternKit.Core.dll

Store abstraction for durable dead-letter records.

public interface IDeadLetterStore<TPayload>

Type Parameters

TPayload

Methods

EnqueueAsync(DeadLetterMessage<TPayload>, CancellationToken)

Persists a dead-letter message.

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.

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

Parameters

id string

cancellationToken CancellationToken

Returns

ValueTask<DeadLetterMessage<TPayload>>