Interface IPipelineDeadLetterDestination<T>

Namespace

Pipelinez.Core.DeadLettering

Assembly

Pipelinez.dll

Defines a destination that can persist dead-letter records after terminal fault handling.

public interface IPipelineDeadLetterDestination<T> where T : PipelineRecord

Type Parameters

T

The pipeline record type contained in the dead-letter envelope.

Methods

WriteAsync(PipelineDeadLetterRecord<T>, CancellationToken)

Writes a dead-letter record to the configured store.

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