Table of Contents

Class InMemoryDeadLetterDestination<T>

Namespace
Pipelinez.Core.DeadLettering
Assembly
Pipelinez.dll

Stores dead-letter records in memory for testing or simple host scenarios.

public sealed class InMemoryDeadLetterDestination<T> : IPipelineDeadLetterDestination<T> where T : PipelineRecord

Type Parameters

T

The pipeline record type stored in the dead-letter envelopes.

Inheritance
InMemoryDeadLetterDestination<T>
Implements
Inherited Members

Properties

Records

Gets the dead-letter records written to the in-memory destination.

public IReadOnlyList<PipelineDeadLetterRecord<T>> Records { get; }

Property Value

IReadOnlyList<PipelineDeadLetterRecord<T>>

Methods

WriteAsync(PipelineDeadLetterRecord<T>, CancellationToken)

Writes a dead-letter record to the configured store.

public Task WriteAsync(PipelineDeadLetterRecord<T> deadLetterRecord, CancellationToken cancellationToken)

Parameters

deadLetterRecord PipelineDeadLetterRecord<T>

The dead-letter record to persist.

cancellationToken CancellationToken

A token used to cancel the write operation.

Returns

Task