Class RedisDeadLetterSink

Namespace

JD.AI.Workflows.Distributed.Redis

Assembly

JD.AI.Workflows.Distributed.dll

Dead-letter sink that writes failed items to a Redis List.

public sealed class RedisDeadLetterSink : IDeadLetterSink

Inheritance

object

RedisDeadLetterSink

Implements

IDeadLetterSink

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RedisDeadLetterSink(IConnectionMultiplexer, RedisWorkflowOptions)

Initializes the sink.

public RedisDeadLetterSink(IConnectionMultiplexer redis, RedisWorkflowOptions options)

Parameters

redis IConnectionMultiplexer

options RedisWorkflowOptions

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