Rabbitmq List Queues

RabbitMQ Queue Status

Overview

Quick inspection of RabbitMQ queue status across environments. Lists message counts, consumer counts, and identifies DLQs with pending messages.

Commands

List all DLQs with messages

kubectl --context=<env> exec -n shared-infra <rabbitmq-pod> -- \
  rabbitmqctl list_queues -p data_platform name messages consumers state \
  | grep "dead_letter" | awk '$2 > 0'

Check specific service queues

kubectl --context=<env> exec -n shared-infra <rabbitmq-pod> -- \
  rabbitmqctl list_queues -p data_platform name messages consumers state \
  | grep "<service>"

List all queues with messages (non-empty)

kubectl --context=<env> exec -n shared-infra <rabbitmq-pod> -- \
  rabbitmqctl list_queues -p data_platform name messages consumers state \
  | awk 'NR==1 || $2 > 0'

Check consumer health (queues with 0 consumers)

kubectl --context=<env> exec -n shared-infra <rabbitmq-pod> -- \
  rabbitmqctl list_queues -p data_platform name messages consumers state \
  | grep -v "dead_letter" | awk '$3 == 0 && $2 > 0'

Pod Discovery

Output Format

Present results as a table:

| Queue | Messages | Consumers | State |
|---|---|---|---|
| service:entity:persisted | 0 | 2 | running |
| service:entity:persisted.dead_letter | 47 | 0 | running |

Flag any issues:

• DLQ with messages > 0 → suggest rabbitmq-triage-dlq
• Main queue with 0 consumers → service may be down
• Main queue with growing messages → consumers may be slow