Purge RabbitMQ Queues with the Management Plugin

purge-queues.sh

#!/bin/bash

# Function to purge a queue
purge_queue() {
    queue_name="$1"
    echo "Purging queue: $queue_name"
    docker exec CONTAINER_NAME rabbitmqadmin -u USER -p PWD -H 0.0.0.0 -P MANAGEMENT_PORT purge queue name="$queue_name" > /dev/null
}

# Fetch all queues
queues=$(docker exec CONTAINER_NAME rabbitmqadmin -u USER -p PWD -H 0.0.0.0 -P MANAGEMENT_PORT list queues | awk '$4 > 0 && $2 != "name" {print $2}')

# Purge each queue
for queue in $queues
do
    purge_queue "$queue"
done

echo "All queues purged."