The functionality described in this article is available in the meshIQ Platform versions 11.1.1 and later.
For a quick overview of what's new or changed, visit the meshIQ Highlights page for a version-by-version breakdown.
Jump to Section:
Version 11.2 and Earlier
Version 12.x and Later
Version 11.2 and Earlier
RabbitMQ queue objects show properties and metrics for RabbitMQ queues.
To create a queue, do the following:
- Click
on the queue viewlet toolbar.
- Enter the Queue Name.
- Select the Queue Type (Quorum, Stream, or Classic).
- To allow the queue to survive RabbitMQ restart, select True from the Durable list.
- If you want this queue to be automatically deleted when the last consumer unsubscribes, select True from the Auto delete list.
- If this queue will be limited to one consumer, select True from the Exclusive list.
- If the queue is exclusive (Exclusive is set to True), enter the tag for its consumer in the Exclusive Customer Tag field.
- The Policy and Operator Policy are set based on the queue's name value or regex matching.
- Click OK to save the queue.
General tab
Name |
Description |
Queue Name | Name of the queue |
Queue Type | Quorum, Stream, or Classic |
Durable |
If True, the queue will survive RabbitMQ restart. |
Auto delete |
If True, the queue will be automatically deleted when the last consumer unsubscribes. |
Exclusive |
If True, the queue is limited to only one consumer. |
Remote Node Name |
Node name made from combining the prefix "rabbit" and a hostname (for example, rabbit@node). |
Exclusive Consumer Tag |
If the queue is Exclusive, the tag that identifies its one consumer. |
Policy | Set based on name value or regex matching. |
Operator Policy | Set based on name value or regex matching. |
Message Details tab
Name |
Description |
Ready Messages RAM | Number of objects stored in RAM used by ready messages |
Unacked Messages RAM | Number of objects stored in RAM used by unacknowledged messages |
Messages Persistent | Number of persistent messages in the queue. |
Messages RAM |
Number of messages stored in RAM |
Messages Page Out | Messages saved by RabbitMQ to disk to save RAM. |
Messages Bytes | Total size in bytes of all messages in the queue. |
Messages Bytes Persistent |
Total size (in bytes) of persistent messages in the queue. |
Messages Bytes RAM | Amount of RAM used by messages. |
Messages Bytes Ready |
Total size in bytes of messages ready to be delivered. |
Messages Bytes Unacked |
Total size in bytes of all delivered, but as of yet unacknowledged, messages in the queue. |
Messages Bytes Page Out |
Total size (in bytes) of messages saved by RabbitMQ to disk to save RAM. |
Memory |
Memory used by Erlang process for the queue (stack, heap, and internal structures). |
Head Message Timestamp |
Timestamp of topmost message |
Message Rates tab
Name |
Description |
Publish | Messages that have been provided to RabbitMQ. |
Publish Rate | Messages published per second. |
Confirm | Delivered messages for which a confirmation has been received. |
Confirm Rate |
Messages per second confirmed by the server. |
Deliver (Auto-Ack) | Messages delivered to the subscriber (consumer) and automatically acknowledged by RabbitMQ upon delivery. |
Deliver (Auto-Ack) Rate | Deliver (Auto-Ack) messages per second. |
Deliver (Manuel Ack) |
Number of messages that are manually acknowledged by the consumer after being processed. |
Deliver (Manuel Ack) Rate | Messages per second that are manually acknowledged by the consumer after being processed. |
Deliver Get | Number of messages delivered directly to queues (basic get) instead of being sent through a consumer. |
Deliver Get Rate | Number of messages per second that are delivered directly to queues (basic get) instead of being sent through a consumer. |
Consumer Ack | Number of messages have been acknowledged by the consumer. |
Consumer Ack Rate | Number of messages per second that are acknowledged by the consumer. |
Redeliver |
Number of messages waiting to be resent. When message delivery fails (no acknowledgement is received to indicate that a message was delivered), an attempt is made to redeliver the message. |
Redeliver Rate | Number of messages per second that are awaiting redelivery. |
Messages tab
Name |
Description |
Messages | Total number of messages in this queue. |
Message Rate | Total number of messages in this queue per second. |
Ready Messages | The number of messages in this queue that are available to be delivered, but not yet delivered. |
Ready Messages Rate |
The number of ready messages that are accumulating per second. |
Unacked Messages |
The number of delivered messages for which the server is awaiting acknowledgment. |
Unacked Messages Rate | The number of unacknowledged delivered messages that are accumulating per second. |
Queue Consumers tab
Name |
Description |
Consumers | Number of consumers. |
Consumer Capacity (previously called Consumer Utilisation) | The metric is computed as the percentage of the time that the queue is able to immediately deliver messages to consumers. |
Consumer Utilisation | Measures the queue's availability to take new messages as a ratio of available time to total time. |
Single Active Consumer Tag |
Tag that identifies the Single Active Consumer for the queue. |
Recoverable Slaves | The list of names of slaves. |
Leader | The name of the leading object. |
Runtime Metrics tab
Name |
Description |
Reductions |
A reduction is a unit of scheduler/CPU consumption in the Erlang runtime environment. The Reductions Rate is the number of reductions per second. More information about reductions can be found by searching the Erlang documentation. |
Reductions Rate | |
Maximum Heap Size In Words | Maximum size of memory heap as measured in Erlang words. |
Minimum Binary Virtual Heap Size In Words |
Maximum size of binary heap as measured in Erlang words. |
Maximum Generational Collections Before Fullsweep | Generational garbage collections make a distinction between newer objects and long-lived ones. This is the maximum number of Generational Collections allowed before a Full Garbage Collection takes place (the full heap is collected). |
Number of Minor GCs | Number of minor garbage collections since last major garbage collection. |
Status tab
________________________________________________________________________________________________________________
Version 12.x and Later
RabbitMQ queue objects show properties and metrics for RabbitMQ queues.
Create a Queue
To create a Queue:
- Click the Add Queue
button in the Queue viewlet. The Select Object Path window opens.
- Specify the object path for the new Queue, then click Select path.
- The RabbitMQ Queue Create Window opens.
- In the General tab, enter the Queue Name.
- Select the Queue Type (Default for virtual host, Quorum, Stream, or Classic).
- To allow the queue to survive RabbitMQ restart, select True from the Durable list.
- If you want this queue to be automatically deleted when the last consumer unsubscribes, select True from the Auto delete list.
- If this queue will be limited to one consumer, select True from the Exclusive list.
- If the queue is exclusive (Exclusive is set to True), enter the tag for its consumer in the Exclusive Customer Tag field.
- The Policy and Operator Policy are set based on the queue's name value or regex matching.
- The Arguments tab lets you configure optional advanced settings for the queue. Click Argument Description to learn how each argument affects the queue’s behavior.
Click the file button to view the list of available arguments.
To see the description of a specific argument, click the Infobutton next to it.
Select an argument, provide a value and data type, and then click thebutton to add it.
Repeat this process to add more arguments as needed. - Click Ok to create the Queue immediately. Alternatively, click Schedule to create it at a later time (see Scheduling for details).
- After creating a Queue, the Queue Properties dialog displays tabs such as General, Message Details, Message Rates, Messages, Queue Consumers, Runtime Metrics, Status, Arguments, and Custom Attributes for detailed configuration and monitoring.
To access these:
-
Select the Queue from the viewlet.
-
Click Properties from the Selected menu.
-
General Properties tab
Name |
Description |
Queue Name | Name of the queue |
Queue Type | Quorum, Stream, or Classic |
Durable |
If True, the queue will survive RabbitMQ restart. |
Auto delete |
If True, the queue will be automatically deleted when the last consumer unsubscribes. |
Exclusive |
If True, the queue is limited to only one consumer. |
Remote Node Name |
Node name made from combining the prefix "rabbit" and a hostname (for example, rabbit@node). |
Exclusive Consumer Tag |
If the queue is Exclusive, the tag that identifies its one consumer. |
Policy | Set based on name value or regex matching. |
Operator Policy | Set based on name value or regex matching. |
Message Details tab
Name |
Description |
Ready Messages RAM | Number of objects stored in RAM used by ready messages |
Unacked Messages RAM | Number of objects stored in RAM used by unacknowledged messages |
Messages Persistent | Number of persistent messages in the queue. |
Messages RAM |
Number of messages stored in RAM |
Messages Page Out | Messages saved by RabbitMQ to disk to save RAM. |
Messages Bytes | Total size in bytes of all messages in the queue. |
Messages Bytes Persistent |
Total size (in bytes) of persistent messages in the queue. |
Messages Bytes RAM | Amount of RAM used by messages. |
Messages Bytes Ready |
Total size in bytes of messages ready to be delivered. |
Messages Bytes Unacked |
Total size in bytes of all delivered, but as of yet unacknowledged, messages in the queue. |
Messages Bytes Page Out |
Total size (in bytes) of messages saved by RabbitMQ to disk to save RAM. |
Memory |
Memory used by Erlang process for the queue (stack, heap, and internal structures). |
Head Message Timestamp |
Timestamp of topmost message |
Message Rates tab
Name |
Description |
Publish | Messages that have been provided to RabbitMQ. |
Publish Rate | Messages published per second. |
Confirm | Delivered messages for which a confirmation has been received. |
Confirm Rate |
Messages per second confirmed by the server. |
Deliver (Auto-Ack) | Messages delivered to the subscriber (consumer) and automatically acknowledged by RabbitMQ upon delivery. |
Deliver (Auto-Ack) Rate | Deliver (Auto-Ack) messages per second. |
Deliver (Manuel Ack) |
Number of messages that are manually acknowledged by the consumer after being processed. |
Deliver (Manuel Ack) Rate | Messages per second that are manually acknowledged by the consumer after being processed. |
Deliver Get | Number of messages delivered directly to queues (basic get) instead of being sent through a consumer. |
Deliver Get Rate | Number of messages per second that are delivered directly to queues (basic get) instead of being sent through a consumer. |
Consumer Ack | Number of messages have been acknowledged by the consumer. |
Consumer Ack Rate | Number of messages per second that are acknowledged by the consumer. |
Redeliver |
Number of messages waiting to be resent. When message delivery fails (no acknowledgement is received to indicate that a message was delivered), an attempt is made to redeliver the message. |
Redeliver Rate | Number of messages per second that are awaiting redelivery. |
Get (Auto Ack) | Number of messages retrieved with automatic acknowledgement. |
Get (Auto Ack Rate) | Number of auto-acknowledged gets per second. |
Get (Manual Ack) | Number of messages retrieved that require manual acknowledgement. |
Get (Manual Ack) Rate | Number of manual-acknowledged gets per second. |
Get (Empty) | Number of attempts to get a message when the queue was empty. |
Get (Empty) Rate | Number of empty gets per second. |
Unroutable (Return) | Number of messages returned as unroutable when the "mandatory" flag is set. |
Unroutable (Return) Rate | Number of unroutable (return) messages per second. |
Unroutable (Drop) | Number of unroutable messages dropped (no "mandatory" flag and no route found). |
Unroutable (Drop) Rate | Number of unroutable (drop) messages per second. |
Disk Reads | Total number of message reads from disk. |
Disk Reads Rate | Number of message reads from disk per second. |
Disk Writes | Total number of message writes to disk. |
Disk Writes Rates | Number of message writes to disk per second. |
Messages tab
Name |
Description |
Messages | Total number of messages in this queue. |
Message Rate | Total number of messages in this queue per second. |
Ready Messages | The number of messages in this queue that are available to be delivered, but not yet delivered. |
Ready Messages Rate |
The number of ready messages that are accumulating per second. |
Unacked Messages |
The number of delivered messages for which the server is awaiting acknowledgment. |
Unacked Messages Rate | The number of unacknowledged delivered messages that are accumulating per second. |
Queue Consumers tab
Name |
Description |
Consumers | Number of consumers. |
Consumer Capacity (previously called Consumer Utilisation) | The metric is computed as the percentage of the time that the queue is able to immediately deliver messages to consumers. |
Consumer Utilisation | Measures the queue's availability to take new messages as a ratio of available time to total time. |
Single Active Consumer Tag |
Tag that identifies the Single Active Consumer for the queue. |
Recoverable Slaves | The list of names of slaves. |
Leader | The name of the leading object. |
Runtime Metrics tab
Name |
Description |
Reductions |
A reduction is a unit of scheduler/CPU consumption in the Erlang runtime environment. The Reductions Rate is the number of reductions per second. More information about reductions can be found by searching the Erlang documentation. |
Reductions Rate | |
Maximum Heap Size In Words | Maximum size of memory heap as measured in Erlang words. |
Minimum Binary Virtual Heap Size In Words |
Maximum size of binary heap as measured in Erlang words. |
Minimum Heap Size in Words | Minimum size of memory heap as measured in Erlang words. |
Maximum Generational Collections Before Fullsweep | Generational garbage collections make a distinction between newer objects and long-lived ones. This is the maximum number of Generational Collections allowed before a Full Garbage Collection takes place (the full heap is collected). |
Number of Minor GCs | Number of minor garbage collections since last major garbage collection. |
Status tab
Argument tab
Arguments Description
Argument | Key name | Description |
Auto Expire | x-expires | Automatically deletes the queue after a set period of inactivity. |
Message TTL | x-message-ttl | Sets how long messages live in the queue before they expire (in milliseconds). |
Overflow Behaviour | x-overflow | Defines how RabbitMQ handles the queue when it exceeds its maximum length (e.g., drop messages or reject publishes). |
Single Active Consumer | x-single-active-consumer | Allows only one consumer to actively consume messages from the queue at a time. |
Dead Letter Exchange | x-dead-letter-exchange | Routes messages that expire or are rejected to a specified exchange. |
Dead Letter Routing Key | x-dead-letter-routing-key | Specifies the routing key to use when forwarding dead-lettered messages. |
Max Length | x-max-length | Limits the maximum number of messages that the queue can hold. |
Max Length Bytes | x-max-length-bytes | Limits the maximum total size (in bytes) of messages in the queue. |
Leader Locator | x-queue-leader-locator | Configures how leadership is selected in a quorum queue (for redundancy and failover). |
You can also create your own custom properties on the Custom Attributes tab.