Skip to main content

RabbitMQ operations

v0.1.10

Cluster, queue, exchange, binding, connection, channel, and consumer inventory plus narrow operator actions (purge_queue, set_policy, force_close_connection). Uses rabbitmqctl + rabbitmqadmin on the runner host.

15 allowed by default 2 need approval by default 1 denied by default
Pack ID
rabbitmq
Vendor
emisar
OS
linux
Actions
18
Required binaries. Install these on the host before relying on the pack — an action that calls a missing one fails at run time.
rabbitmqctl

Install

emisar pack install fetches this pack, re-validates it, and verifies its content hash against the --hash below — the exact bytes this page was rendered against, so a tampered copy is rejected — before copying it into the runner's packs dir. The command reloads a running daemon itself; no manual restart.

on the runner host
sudo emisar pack install rabbitmq --hash sha256:3002548b329c71d5f437728ed25fdf83615ffeea0cc465395cdc5ace3db8b01e

Actions 18 total

View on GitHub
  • rmq.close_connection exec high

    rabbitmqctl close_connection

    Forcibly closes one AMQP connection. Whatever client owned it must reconnect.

    View source on GitHub
  • rmq.cluster_status exec low

    rabbitmqctl cluster_status

    Show cluster summary: nodes, alarms, partitions.

    View source on GitHub
  • rmq.list_bindings exec low

    rabbitmqctl list_bindings

    List all bindings between exchanges and queues.

    View source on GitHub
  • rmq.list_channels exec low

    rabbitmqctl list_channels

    List all open channels with consumer + prefetch + ack stats.

    View source on GitHub
  • rmq.list_connections exec low

    rabbitmqctl list_connections

    List all open AMQP connections with client + user + channels.

    View source on GitHub
  • rmq.list_consumers exec low

    rabbitmqctl list_consumers

    List all active consumers + their queue + ack-mode + prefetch.

    View source on GitHub
  • rmq.list_exchanges exec low

    rabbitmqctl list_exchanges

    List all exchanges with type + durability.

    View source on GitHub
  • rmq.list_nodes exec low

    Known cluster nodes

    List all known cluster nodes.

    View source on GitHub
  • rmq.list_parameters exec low

    rabbitmqctl list_parameters

    List runtime parameters (federation upstreams, shovel definitions, etc).

    View source on GitHub
  • rmq.list_policies exec low

    rabbitmqctl list_policies

    List all set policies (HA, federation, shovel, etc).

    View source on GitHub
  • rmq.list_queues exec low

    rabbitmqctl list_queues

    List all queues with name, messages_ready, messages_unacknowledged, consumers, memory. The canonical "is anything backing up?" check.

    View source on GitHub
  • rmq.list_users exec low

    rabbitmqctl list_users

    List all users + tags.

    View source on GitHub
  • rmq.list_vhosts exec low

    rabbitmqctl list_vhosts

    List all virtual hosts.

    View source on GitHub
  • rmq.node_health_check exec low

    rabbitmq-diagnostics check_running

    Check health — confirms the local node is running and reachable.

    View source on GitHub
  • rmq.purge_queue exec critical

    rabbitmqctl purge_queue

    Drops every message in one queue. Unprocessed messages are lost.

    View source on GitHub
  • rmq.start_app exec medium

    rabbitmqctl start_app

    Start the RabbitMQ application within an already-running node. Companion to stop_app, used during cluster joins/leaves.

    View source on GitHub
  • rmq.stop_app exec high

    rabbitmqctl stop_app

    Stop the RabbitMQ application while keeping the Erlang node running. Required before reset/join_cluster. All clients disconnect.

    View source on GitHub
  • rmq.sync_queue exec medium

    rabbitmqctl sync_queue

    Force a mirrored classic queue to sync with its master. Producers and consumers continue to operate; the sync runs in the background. Use when an unsynced mirror is blocking a master failover.

    View source on GitHub