Class RabbitMqPipelineBuilderExtensions

Namespace

Pipelinez.RabbitMQ

Assembly

Pipelinez.RabbitMQ.dll

Provides RabbitMQ transport extension methods for PipelineBuilder<T>.

public static class RabbitMqPipelineBuilderExtensions

Inheritance

object

RabbitMqPipelineBuilderExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

WithRabbitMqDeadLetterDestination<T>(PipelineBuilder<T>, RabbitMqDeadLetterOptions, Func<PipelineDeadLetterRecord<T>, RabbitMqPublishMessage>)

Configures the pipeline to write Pipelinez dead-letter records to RabbitMQ.

public static PipelineBuilder<T> WithRabbitMqDeadLetterDestination<T>(this PipelineBuilder<T> builder, RabbitMqDeadLetterOptions options, Func<PipelineDeadLetterRecord<T>, RabbitMqPublishMessage> messageMapper) where T : PipelineRecord

Parameters

builder PipelineBuilder<T>

The pipeline builder to configure.

options RabbitMqDeadLetterOptions

The RabbitMQ dead-letter destination options.

messageMapper Func<PipelineDeadLetterRecord<T>, RabbitMqPublishMessage>

Maps the dead-letter envelope into the RabbitMQ message to publish.

Returns

PipelineBuilder<T>

The same builder for chaining.

Type Parameters

T

The pipeline record type.

WithRabbitMqDestination<T>(PipelineBuilder<T>, RabbitMqDestinationOptions, Func<T, RabbitMqPublishMessage>)

Configures the pipeline to publish records to RabbitMQ.

public static PipelineBuilder<T> WithRabbitMqDestination<T>(this PipelineBuilder<T> builder, RabbitMqDestinationOptions options, Func<T, RabbitMqPublishMessage> messageMapper) where T : PipelineRecord

Parameters

builder PipelineBuilder<T>

The pipeline builder to configure.

options RabbitMqDestinationOptions

The RabbitMQ destination options.

messageMapper Func<T, RabbitMqPublishMessage>

Maps a pipeline record to the RabbitMQ message to publish.

Returns

PipelineBuilder<T>

The same builder for chaining.

Type Parameters

T

The pipeline record type.

WithRabbitMqSource<T>(PipelineBuilder<T>, RabbitMqSourceOptions, Func<RabbitMqDeliveryContext, T>)

Configures the pipeline to consume records from a RabbitMQ queue.

public static PipelineBuilder<T> WithRabbitMqSource<T>(this PipelineBuilder<T> builder, RabbitMqSourceOptions options, Func<RabbitMqDeliveryContext, T> recordMapper) where T : PipelineRecord

Parameters

builder PipelineBuilder<T>

The pipeline builder to configure.

options RabbitMqSourceOptions

The RabbitMQ source options.

recordMapper Func<RabbitMqDeliveryContext, T>

Maps a RabbitMQ delivery into a pipeline record.

Returns

PipelineBuilder<T>

The same builder for chaining.

Type Parameters

T

The pipeline record type.