Interface IQuorumQueueSpecification
public interface IQuorumQueueSpecification
Methods
ConsumerTimeout(TimeSpan)
Sets the x-consumer-timeout queue argument (milliseconds).
Defines the consumer timeout per queue. If the consumer doesn't handle a message within the timeout, the consumer is considered blocked. See the ITimeout interface for more details. The In the event OnDeliveryRelease is called. See the documentation: https://www.rabbitmq.com/blog/2026/04/23/rabbitmq-4.3-release#consumer-timeouts
IQuorumQueueSpecification ConsumerTimeout(TimeSpan timeout)
Parameters
timeoutTimeSpan
Returns
DeadLetterStrategy(QuorumQueueDeadLetterStrategy)
IQuorumQueueSpecification DeadLetterStrategy(QuorumQueueDeadLetterStrategy strategy)
Parameters
strategyQuorumQueueDeadLetterStrategy
Returns
DelayedRetryMax(TimeSpan)
Set the maximum delay for delayed retry (in milliseconds).
IQuorumQueueSpecification DelayedRetryMax(TimeSpan max)
Parameters
maxTimeSpanMaximum retry delay. Must be positive.
Returns
- See Also
DelayedRetryMin(TimeSpan)
Set the minimum delay for delayed retry (in milliseconds).
The delay grows linearly with the delivery count: min(min * delivery_count, max).
IQuorumQueueSpecification DelayedRetryMin(TimeSpan min)
Parameters
minTimeSpanMinimum retry delay. Must be positive.
Returns
- See Also
DelayedRetryType(QuorumQueueDelayedRetryType)
Set the delayed retry type.
Defines the conditions for delaying a message when it is returned to the queue. You must also call DelayedRetryMin(TimeSpan) to configure the minimum retry delay.
Delayed retry support for quorum queues requires RabbitMQ 4.3+.
IQuorumQueueSpecification DelayedRetryType(QuorumQueueDelayedRetryType type)
Parameters
typeQuorumQueueDelayedRetryTypeThe delayed retry condition.
Returns
- See Also
DeliveryLimit(int)
IQuorumQueueSpecification DeliveryLimit(int limit)
Parameters
limitint
Returns
Queue()
IQueueSpecification Queue()
Returns
QuorumInitialGroupSize(int)
IQuorumQueueSpecification QuorumInitialGroupSize(int size)
Parameters
sizeint
Returns
QuorumTargetGroupSize(int)
IQuorumQueueSpecification QuorumTargetGroupSize(int size)
Parameters
sizeint