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
-
IDeadLetterStore<TPayload>
- 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
messageDeadLetterMessage<TPayload>cancellationTokenCancellationToken
Returns
TryLoadAsync(string, CancellationToken)
Attempts to load a dead-letter message by id.
public ValueTask<DeadLetterMessage<TPayload>?> TryLoadAsync(string id, CancellationToken cancellationToken = default)
Parameters
idstringcancellationTokenCancellationToken
Returns
- ValueTask<DeadLetterMessage<TPayload>>