Class ServiceBusDeadLetterSink

Namespace

JD.AI.Workflows.Distributed.AzureServiceBus

Assembly

JD.AI.Workflows.Distributed.dll

Dead-letter sink that records items to the audit log (no-op default).

public sealed class ServiceBusDeadLetterSink : IDeadLetterSink

Inheritance

object

ServiceBusDeadLetterSink

Implements

IDeadLetterSink

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

ServiceBusDeadLetterSink(ILogger<ServiceBusDeadLetterSink>)

Initializes the sink with a logger.

public ServiceBusDeadLetterSink(ILogger<ServiceBusDeadLetterSink> logger)

Parameters

logger ILogger<ServiceBusDeadLetterSink>

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