Class ServiceBusWorkflowDispatcher

Namespace

JD.AI.Workflows.Distributed.AzureServiceBus

Assembly

JD.AI.Workflows.Distributed.dll

Dispatches WorkflowWorkItem instances to Azure Service Bus.

public sealed class ServiceBusWorkflowDispatcher : IWorkflowDispatcher, IAsyncDisposable

Inheritance

object

ServiceBusWorkflowDispatcher

Implements

IWorkflowDispatcher

IAsyncDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

ServiceBusWorkflowDispatcher(ServiceBusClient, ServiceBusWorkflowOptions)

Initializes the dispatcher.

public ServiceBusWorkflowDispatcher(ServiceBusClient client, ServiceBusWorkflowOptions options)

Parameters

client ServiceBusClient

options ServiceBusWorkflowOptions

Methods

DispatchAsync(WorkflowWorkItem, CancellationToken)

Dispatches a workflow work item for execution.

public Task DispatchAsync(WorkflowWorkItem item, CancellationToken ct = default)

Parameters

item WorkflowWorkItem

The work item to dispatch.

ct CancellationToken

Cancellation token.

Returns

Task

DisposeAsync()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.

public ValueTask DisposeAsync()

Returns

ValueTask

A task that represents the asynchronous dispose operation.