Interface IConsumerBuilder.IQuorumOptions

Namespace

RabbitMQ.AMQP.Client

Assembly

RabbitMQ.AMQP.Client.dll

Options for consumers of quorum queues.

public interface IConsumerBuilder.IQuorumOptions

Methods

Builder()

IConsumerBuilder Builder()

Returns

IConsumerBuilder

SingleActiveConsumerStateChanged(SingleActiveConsumerStateHandler?)

Registers a callback for single-active-consumer state on a quorum queue, using FLOW link-state (rabbitmq:active) from the broker.

IConsumerBuilder.IQuorumOptions SingleActiveConsumerStateChanged(SingleActiveConsumerStateHandler? handler)

Parameters

handler SingleActiveConsumerStateHandler

Delegate invoked when the broker reports SAC state; pass null to clear.

Returns

IConsumerBuilder.IQuorumOptions

The builder for fluent configuration.

Remarks

The callback runs on AMQP.Net Lite's I/O thread; do not block. This callback is intended for use with quorum queues, such as when using Queue(IQueueSpecification) with a specification that declares a quorum queue (for example Quorum() or Type(QueueType) with QUORUM).

Not compatible with DirectReplyTo.

Exceptions

ConsumerException

At BuildAndStartAsync(CancellationToken) when DirectReplyTo is selected.