The functionality described in this article is available in the meshIQ Platform versions 11.1.1 and later. See meshIQ platform Highlights v11.1 for an overview of feature changes.
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. |