Class AzureServiceBusPipelineDestination<T>

Namespace

Pipelinez.AzureServiceBus.Destination

Assembly

Pipelinez.AzureServiceBus.dll

Publishes pipeline records to an Azure Service Bus queue or topic.

public class AzureServiceBusPipelineDestination<T> : PipelineDestination<T>, IPipelineDestination<T>, IFlowDestination<PipelineContainer<T>>, IPipelineExecutionConfigurable, IPipelineRetryConfigurable<T> where T : PipelineRecord

Type Parameters

T

The pipeline record type.

Inheritance

object

PipelineDestination<T>

AzureServiceBusPipelineDestination<T>

Implements

IPipelineDestination<T>

IFlowDestination<PipelineContainer<T>>

IPipelineExecutionConfigurable

IPipelineRetryConfigurable<T>

Inherited Members

PipelineDestination<T>.Logger

PipelineDestination<T>.Completion

PipelineDestination<T>.AsTargetBlock()

PipelineDestination<T>.StartAsync(CancellationTokenSource)

PipelineDestination<T>.Initialize(Pipeline<T>)

PipelineDestination<T>.ConfigureExecutionOptions(PipelineExecutionOptions)

PipelineDestination<T>.GetExecutionOptions()

PipelineDestination<T>.ConfigureRetryPolicy(PipelineRetryPolicy<T>)

PipelineDestination<T>.GetRetryPolicy()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AzureServiceBusPipelineDestination(AzureServiceBusDestinationOptions, Func<T, ServiceBusMessage>)

Initializes a new Azure Service Bus destination.

public AzureServiceBusPipelineDestination(AzureServiceBusDestinationOptions options, Func<T, ServiceBusMessage> messageMapper)

Parameters

options AzureServiceBusDestinationOptions

The Azure Service Bus destination options.

messageMapper Func<T, ServiceBusMessage>

Maps a pipeline record to the Service Bus message to publish.

Methods

ExecuteAsync(T, CancellationToken)

Executes the destination logic for a successfully processed record.

protected override Task ExecuteAsync(T record, CancellationToken cancellationToken)

Parameters

record T

The record to write.

cancellationToken CancellationToken

The cancellation token for the execution.

Returns

Task

Initialize()

Provides an opportunity for the destination to initialize transport-specific state.

protected override void Initialize()