Class InMemoryDeadLetterSink

Namespace

JD.AI.Workflows.Distributed.InMemory

Assembly

JD.AI.Workflows.Distributed.dll

In-memory dead-letter sink that retains failed items in memory for inspection.

public sealed class InMemoryDeadLetterSink : IDeadLetterSink

Inheritance

object

InMemoryDeadLetterSink

Implements

IDeadLetterSink

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Items

All dead-lettered items in insertion order.

public IReadOnlyList<DeadLetteredItem> Items { get; }

Property Value

IReadOnlyList<DeadLetteredItem>

Methods

DeadLetterAsync(WorkflowWorkItem, string, Exception?, CancellationToken)

Records a dead-lettered item with its reason.

public Task DeadLetterAsync(WorkflowWorkItem item, string reason, Exception? exception = null, CancellationToken ct = default)

Parameters

item WorkflowWorkItem

reason string

exception Exception

ct CancellationToken

Returns

Task