Class RabbitMqConsumeOptions

Namespace: Ratatoskr.RabbitMq.Config

Assembly: Ratatoskr.RabbitMq.dll

RabbitMQ configuration for consume channels. Exposes exchange, queue, consumer, and retry settings.

public class RabbitMqConsumeOptions

Inheritance: object

RabbitMqConsumeOptions

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RabbitMqConsumeOptions(RabbitMqChannelOptions): RabbitMQ configuration for consume channels. Exposes exchange, queue, consumer, and retry settings.

Methods

WithAutoAck(bool): Enables or disables auto-acknowledgement of messages.

WithDirectExchange(): Configures a direct exchange with exact routing key matching.

WithDurableQueue(): Configures a durable queue (survives broker restarts, not exclusive, not auto-deleted). This is the default queue configuration.

WithExchangeAutoDelete(bool): Sets whether the exchange is deleted when the last queue is unbound.

WithExchangeDurable(bool): Sets whether the exchange survives broker restarts.

WithExchangeType(RabbitMqExchangeType): Sets the exchange type.

WithFanoutExchange(): Configures a fanout exchange that broadcasts to all bound queues.

WithPrefetch(ushort): Sets the prefetch count (max unacknowledged messages per consumer).

WithQueueArguments(IDictionary<string, object?>): Sets additional queue arguments passed to RabbitMQ on declaration.

WithQueueName(string): Sets the queue name. Required for consume channels.

WithQueueType(QueueType): Sets the queue implementation type (Classic or Quorum).

WithRetry(Action<RetryOptions>): Configures retry behavior using a builder callback.

WithRetry(int, TimeSpan?): Configures retry behavior with max retries and optional delay.

WithTopicExchange(): Configures a topic exchange with pattern-based routing.

WithTransientQueue(): Configures a transient queue (non-durable, not exclusive, auto-deleted when empty). Suitable for temporary or test queues.

Edit this page