Is it possible to auto-delete a QuorumQueue in RabbitMQ? I am using MassTransit and can't seem to get it to work. Any ideas why or how I can achieve it?
config.ReceiveEndpoint(settings.RabbitMq.CommandName + "-" + settings.ServiceId, e => {
e.AutoDelete = true;
e.Durable = true;
e.ConfigureConsumer<ModelA>(context);
e.SetQuorumQueue();
});
You might read the documentation to understand the differences between Quorum queues and regular queues, but they are extensive.
Specifically, they can only be durable, and are not meant to be temporary.
Oh, they also require a quorum to operate, which is at least 2 of 3 nodes.
The latest version of MassTransit allows the use of quorum queues for temporary queues as well, including the bus endpoint and job consumer instance endpoints. These use expiration to ensure they are automatically removed when no longer required. Recent versions of RabbitMQ are required for this to work.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With