SetQuorumQueue using the ConfigureEndpoints method

[MichelRoor]

Hi,

I'm currently looking into using quorum queues for RabbitMQ and I was wondering what options I have to enable this setting.

From what I understand, the setQuorumQueue method can be used on the ReceiveEndpointConfigurator something like this:

busRegistrationConfigurator.UsingRabbitMq((context, cfg) =>
  {
    // host setup etc.

    cfg.ReceiveEndpoint('queue name', configurator => 
      {
        configurator.SetQuorumQueue();
      });
  });

This approach requires me to do this for all our current (and upcoming) queues. I'm looking for a solution to do this for all the queues at once. Something like:

busRegistrationConfigurator.UsingRabbitMq((context, cfg) =>
  {
    // host setup etc.

    cfg.SetQuorumQueue();
    cfg.ConfigureEndpoints(context);
  });

Is this possible with the latest version? Or is this something that isn't supported at the moment?

Thanks for the information/help! :)

[phatboyg]

x.AddConfigureEndpointsCallback((name, cfg) =>
{
    if(cfg is IRabbitMqEndpointConfigurator rmq)
        rmq.SetQuorumQueue();
});

[MichelRoor]

that works for me. Thank you! 😄

[deathchurch]

When using ISendEndpointProvider and the Send method with the "queue:" URI syntax is there a way of setting the queue that gets created to be of type Quorum rather than classic?

[phatboyg]

I don't believe so, no. You should be sending to exchanges instead of queues to avoid mismatches between what the consumer configures and what send may create instead.

[deathchurch]

Thanks for the quick reply, I could only find setting the default queue type on a vhost at creation would make sure any queues get created as quorum, and this works when using Send.