Interface IWorkflowWorker

Namespace

JD.AI.Workflows.Distributed

Assembly

JD.AI.Workflows.Distributed.dll

Pulls and executes WorkflowWorkItem instances from a queue. Implementations should be registered as IHostedService.

public interface IWorkflowWorker

Methods

ProcessAsync(WorkflowWorkItem, CancellationToken)

Processes a single work item. Callers control acknowledgment or dead-lettering based on the returned WorkItemResult.

Task<WorkItemResult> ProcessAsync(WorkflowWorkItem item, CancellationToken ct = default)

Parameters

item WorkflowWorkItem

ct CancellationToken

Returns

Task<WorkItemResult>