Class RabbitMqSourceOptions

Namespace

Pipelinez.RabbitMQ.Configuration

Assembly

Pipelinez.RabbitMQ.dll

Configures a RabbitMQ queue source.

public sealed class RabbitMqSourceOptions

Inheritance

object

RabbitMqSourceOptions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Connection

Gets or sets the RabbitMQ connection options.

public RabbitMqConnectionOptions Connection { get; set; }

Property Value

RabbitMqConnectionOptions

ConsumerArguments

Gets or sets optional consumer arguments.

public IDictionary<string, object?>? ConsumerArguments { get; set; }

Property Value

IDictionary<string, object>

ConsumerDispatchConcurrency

Gets or sets RabbitMQ.Client consumer dispatch concurrency.

public ushort ConsumerDispatchConcurrency { get; set; }

Property Value

ushort

ConsumerTag

Gets or sets an optional RabbitMQ consumer tag.

public string? ConsumerTag { get; set; }

Property Value

string

ExclusiveConsumer

Gets or sets a value indicating whether the consumer should be exclusive.

public bool ExclusiveConsumer { get; set; }

Property Value

bool

GlobalQos

Gets or sets a value indicating whether QoS should be global to the channel.

public bool GlobalQos { get; set; }

Property Value

bool

NoLocal

Gets or sets a value indicating whether the consumer should use no-local behavior.

public bool NoLocal { get; set; }

Property Value

bool

PrefetchCount

Gets or sets the maximum number of unacknowledged deliveries for the consumer.

public ushort PrefetchCount { get; set; }

Property Value

ushort

Queue

Gets or sets the queue to consume.

public RabbitMqQueueOptions Queue { get; set; }

Property Value

RabbitMqQueueOptions

Settlement

Gets or sets source settlement behavior.

public RabbitMqSourceSettlementOptions Settlement { get; set; }

Property Value

RabbitMqSourceSettlementOptions

Topology

Gets or sets optional topology declaration or validation options.

public RabbitMqTopologyOptions Topology { get; set; }

Property Value

RabbitMqTopologyOptions

Methods

Validate()

Validates the source options and returns the same instance when valid.

public RabbitMqSourceOptions Validate()

Returns

RabbitMqSourceOptions

The validated options instance.