Class RabbitMqPipelineDestination<T>

Namespace

Pipelinez.RabbitMQ.Destination

Assembly

Pipelinez.RabbitMQ.dll

Publishes pipeline records to RabbitMQ.

public class RabbitMqPipelineDestination<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>

RabbitMqPipelineDestination<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

RabbitMqPipelineDestination(RabbitMqDestinationOptions, Func<T, RabbitMqPublishMessage>)

Initializes a new RabbitMQ destination.

public RabbitMqPipelineDestination(RabbitMqDestinationOptions options, Func<T, RabbitMqPublishMessage> messageMapper)

Parameters

options RabbitMqDestinationOptions

The RabbitMQ destination options.

messageMapper Func<T, RabbitMqPublishMessage>

Maps a pipeline record to the RabbitMQ 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()