RabbitMQ

Use RabbitMQ's Management HTTP API to publish and inspect messages, manage queue topology, and check broker health. Messages are published to exchanges and routed through bindings into queues.

The default acknowledgement mode requeues messages after reading them, so an inspection workflow can leave messages available to other consumers.

Before you start

• The management plugin must be enabled and reachable from Sim. It listens on port 15672 by default and is separate from the AMQP port (5672). Self-hosted brokers enable it with rabbitmq-plugins enable rabbitmq_management; managed providers expose it as a management or console URL.
• The management URL must use https unless the broker is on a loopback host. Credentials travel on every request as HTTP basic auth, so plain http to a remote broker would put them on the wire in the clear — Sim rejects it rather than sending them.
• The user you authenticate as needs the management tag at minimum, plus read and write permissions on the virtual host you target. Administrative operations require broader permissions.
• Publishing and reading messages over the HTTP API is convenient but not a high-throughput transport — RabbitMQ opens a new connection per request. It is well suited to workflow-rate traffic, inspection, and operational automation; a service consuming thousands of messages per second should use an AMQP client instead.
• Queue statistics such as message and consumer counts are collected on an interval, so a queue declared moments ago may report them as empty until the broker's next sample.
• Reading messages is bounded per call so one retrieval cannot exceed Sim's response limit. A batch is capped at 50 messages, payloads are truncated (each message reports whether it was), and a large batch shortens payloads further. AMQP properties and headers are returned in full — the broker offers no way to truncate them — so retrieving several messages carrying very large headers may still hit the limit; lower the count if that happens.

Use the block

Connect agents to a RabbitMQ broker through its Management HTTP API. Publish messages to exchanges, read messages off queues, declare queues, exchanges, bindings, and policies, and inspect broker health, queue depth, consumers, connections, and cluster nodes. Works with self-hosted brokers and managed offerings such as CloudAMQP as long as the management plugin is reachable.

Actions

RabbitMQ Publish Message

Publish a message to a RabbitMQ exchange with a routing key. Reports whether the message was routed to at least one queue.

RabbitMQ Get Messages

Retrieve messages from a RabbitMQ queue. Defaults to requeueing the messages so they stay available to real consumers.

RabbitMQ List Queues

List queues in a RabbitMQ virtual host with their depth, consumer count, and configuration.

RabbitMQ Get Queue

Read a single RabbitMQ queue, including its depth, consumer count, and declaration settings.

RabbitMQ Create Queue

Declare a RabbitMQ queue. Declaring a queue that already exists with the same settings succeeds without changing it.

RabbitMQ Delete Queue

Delete a RabbitMQ queue and every message still in it. Can be guarded so the delete only happens when the queue is unused or empty.

RabbitMQ Purge Queue

Discard every ready message in a RabbitMQ queue while leaving the queue itself in place.

RabbitMQ List Exchanges

List exchanges in a RabbitMQ virtual host with their type and declaration settings.

RabbitMQ Get Exchange

Read a single RabbitMQ exchange and the settings it was declared with.

RabbitMQ Create Exchange

Declare a RabbitMQ exchange. Declaring an exchange that already exists with the same settings succeeds without changing it.

RabbitMQ Delete Exchange

Delete a RabbitMQ exchange and every binding attached to it. Publishers targeting it will fail afterwards.

RabbitMQ List Bindings

List the bindings that route messages into a RabbitMQ queue, including the implicit default-exchange binding.

RabbitMQ List Exchange Bindings

List everything an exchange routes to, so you can see which routing keys reach which queues.

RabbitMQ Create Binding

Bind a queue or another exchange to a RabbitMQ exchange so messages matching a routing key are routed to it.

RabbitMQ Delete Binding

Remove a binding so an exchange stops routing its matching messages to that destination.

RabbitMQ Get Overview

Read broker-wide RabbitMQ status: version, cluster name, object totals, queue depth totals, and message rates.

RabbitMQ Health Check

Run one of the broker health checks and report whether it passed. A failing check is a normal result, not a tool error.

RabbitMQ List Nodes

List the cluster nodes with memory, disk, file-descriptor, and alarm state. A fired alarm blocks publishers broker-wide.

RabbitMQ List Virtual Hosts

List the virtual hosts on the broker with their message totals, so you can discover which scopes exist.

RabbitMQ List Connections

List client connections to the broker with their user, state, and channel count. Connections are cluster-wide, not scoped to one virtual host.

RabbitMQ List Channels

List open channels with their prefetch limit and unacknowledged message count, which is where stalled consumers show up. Channels are cluster-wide, not scoped to one virtual host.

RabbitMQ List Consumers

List the consumers subscribed in a virtual host. An empty result for a queue with a backlog means nothing is processing it.

RabbitMQ List Policies

List the policies in a virtual host. Policies are how dead-lettering, TTLs, and length limits get applied to matching queues and exchanges.

RabbitMQ Create Policy

Create or replace a RabbitMQ policy, applying settings such as dead-lettering, TTLs, or length limits to every queue or exchange whose name matches a pattern.

RabbitMQ Delete Policy

Delete a RabbitMQ policy. Every queue and exchange it matched immediately loses the settings it applied.