Class AzureServiceBusPipelineBuilderExtensions

Namespace

Pipelinez.AzureServiceBus

Assembly

Pipelinez.AzureServiceBus.dll

Provides Azure Service Bus transport extension methods for PipelineBuilder<T>.

public static class AzureServiceBusPipelineBuilderExtensions

Inheritance

object

AzureServiceBusPipelineBuilderExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

WithAzureServiceBusDeadLetterDestination<T>(PipelineBuilder<T>, AzureServiceBusDeadLetterOptions, Func<PipelineDeadLetterRecord<T>, ServiceBusMessage>)

Configures the pipeline to write Pipelinez dead-letter records to an Azure Service Bus queue or topic.

public static PipelineBuilder<T> WithAzureServiceBusDeadLetterDestination<T>(this PipelineBuilder<T> builder, AzureServiceBusDeadLetterOptions options, Func<PipelineDeadLetterRecord<T>, ServiceBusMessage> messageMapper) where T : PipelineRecord

Parameters

builder PipelineBuilder<T>

The pipeline builder to configure.

options AzureServiceBusDeadLetterOptions

The Azure Service Bus dead-letter destination options.

messageMapper Func<PipelineDeadLetterRecord<T>, ServiceBusMessage>

Maps the dead-letter envelope into the Service Bus message to publish.

Returns

PipelineBuilder<T>

The same builder for chaining.

Type Parameters

T

The pipeline record type.

WithAzureServiceBusDestination<T>(PipelineBuilder<T>, AzureServiceBusDestinationOptions, Func<T, ServiceBusMessage>)

Configures the pipeline to publish records to an Azure Service Bus queue or topic.

public static PipelineBuilder<T> WithAzureServiceBusDestination<T>(this PipelineBuilder<T> builder, AzureServiceBusDestinationOptions options, Func<T, ServiceBusMessage> messageMapper) where T : PipelineRecord

Parameters

builder PipelineBuilder<T>

The pipeline builder to configure.

options AzureServiceBusDestinationOptions

The Azure Service Bus destination options.

messageMapper Func<T, ServiceBusMessage>

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

Returns

PipelineBuilder<T>

The same builder for chaining.

Type Parameters

T

The pipeline record type.

WithAzureServiceBusSource<T>(PipelineBuilder<T>, AzureServiceBusSourceOptions, Func<ServiceBusReceivedMessage, T>)

Configures the pipeline to consume records from an Azure Service Bus queue or topic subscription.

public static PipelineBuilder<T> WithAzureServiceBusSource<T>(this PipelineBuilder<T> builder, AzureServiceBusSourceOptions options, Func<ServiceBusReceivedMessage, T> recordMapper) where T : PipelineRecord

Parameters

builder PipelineBuilder<T>

The pipeline builder to configure.

options AzureServiceBusSourceOptions

The Azure Service Bus source options.

recordMapper Func<ServiceBusReceivedMessage, T>

Maps a Service Bus received message into a pipeline record.

Returns

PipelineBuilder<T>

The same builder for chaining.

Type Parameters

T

The pipeline record type.