RabbitMQ – Quorum Queues

The Quorum queues are designed to provide data safety and require more resources (disk and RAM) than classic queues, and it’s recommended to consider setting up the memory limits.

Note: see the RabbitMQ documentation for more information https://www.rabbitmq.com/quorum-queues.html). 

The Quorum queue supports the following optional arguments that are used to limit the amount of memory each quorum queue will use for the part of its log that is kept in memory.

Note: The optional queue argument can be dynamically changed after queue creation.

x-max-in-memory-length argument - how many (ready) messages a quorum queue can contain in memory before it starts storing them on disk only. Must be a non-negative integer.
x-max-in-memory-bytes argument - total body size for ready messages a quorum queue can contain in memory before it starts storing them on disk only. Must be a non-negative integer.

Configuring Quorum queue memory limit.

1. Open the RabbitMQ Management from a web browser ( http://localhost:15672/).
2. Select Policies on Admin view to add a Quorum queue policy

 

 3. Define a policy

• enter a policy name (it can be anything but ASCII-based names without spaces),
• enter a pattern (a regular expression that matches one or more queue (exchange) names. Any regular expression can be used)
• set apply to (policies can be applied to only queues, only exchanges, or both)
• add definition(s) (a set of key/value pairs) with appropriate type (Number)

         

            4. Click ‘Add/Update policy’ – the policy is added to a queue and you can observe it under User policies, or on queue details.

         

        

         

 

The policy can be deleted at any time.

 

 

You can use ‘+/-‘ on a RabbitMQ view to add/remove columns.