How do I delete all messages from a single queue using the CLI

Question

How do I delete all messages from a single queue using the cli  I have the queue name and I want to clean it

User · Answer

I guess its late but for others reference  this can be done with pika  import pika host ip    host ip channel   pika BlockingConnection pika ConnectionParameters host ip                                                          5672                                                               credentials pika PlainCredentials  username   pwd     channel   print  deleting queue     channel queue delete queue queue name

User · Answer

I have successfully used ampq-purge from amqp-utils to do this   git clone https   github com dougbarth amqp-utils git cd amqp-utils   extracted from Rakefile echo  source  https   rubygems org  gem  amqp      gt  0 7 1  gem  trollop      gt  1 16 2  gem  facets      gt  2 9  gem  clio      gt  0 3 0  gem  json      gt  1 5  gem  heredoc unindent      gt  1 1 2  gem  msgpack      gt  0 4 5    gt  Gemfile bundle install --path  PWD gems export RUBYLIB   export GEM HOME  PWD gems ruby 1 9 1  ruby bin amqp-purge -v -V  vhost -u user -p queue   paste password at prompt

User · Answer

rabbitmqadmin is the perfect tool for this  rabbitmqadmin purge queue name name of the queue to be purged

User · Answer

IMPORTANT NOTE  This will delete all users and config   ALERT     ALERT     I don t suggest this answer until unless you want to delete data from all of the queues  including users and configs  Just Reset it      rabbitmqctl stop app rabbitmqctl reset rabbitmqctl start app

User · Answer

In case you are using RabbitMQ with Docker your steps should be   Connect to container  docker exec -it your container id bash rabbitmqctl purge queue Queue-1  where Queue-1 is queue name

User · Answer

In order to delete only messages from the queue use    sudo rabbitmqctl --node  lt nodename gt  purge queue  lt queue name gt    In order to delete a queue which is empty --if-empty  or has no consumers --if-unused  use    sudo rabbitmqctl --node  lt nodename gt  delete queue  lt queue name gt  --if-empty   or   sudo rabbitmqctl --node  lt nodename gt  delete queue  lt queue name gt  --if-unused

User · Answer

To purge queue you can use following command  more information in API doc    curl -i -u guest guest -XDELETE http   localhost 15672 api queues vhost name queue name contents

User · Answer

RabbitMQ has 2 things under queue   Delete Purge   Delete - will delete the queue  Purge - This will empty the queue  meaning removes messages from the queue but queue still exists

User · Answer

you can directly run this command  sudo rabbitmqctl purge queue queue name

User · Answer

RabbitMQ implements the Advanced Message Queuing Protocol  AMQP  so you can use generic tools for stuff like this   On Debian Ubuntu or similar system  do   sudo apt-get install amqp-tools amqp-delete-queue -q celery    where celery is the name of the queue to delete

[rabbitmq] How do I delete all messages from a single queue using the CLI?

Examples related to rabbitmq