Getting number of messages in a RabbitMQ queue

by

Using pika:

import pika

pika_conn_params = pika.ConnectionParameters(
    host="localhost", port=5672,
    credentials=pika.credentials.PlainCredentials('guest', 'guest'),
)
connection = pika.BlockingConnection(pika_conn_params)
channel = connection.channel()
queue = channel.queue_declare(
    queue="your_queue", durable=True,
    exclusive=False, auto_delete=False
)

print(queue.method.message_count)

Using PyRabbit:

from pyrabbit.api import Client
cl = Client('localhost:55672', 'guest', 'guest')
cl.get_messages('example_vhost', 'example_queue')[0]['message_count']

Using HTTP

Syntax:

curl -i -u user:password http://localhost:15672/api/queues/vhost/queue

Example:

curl -i -u guest:guest http://localhost:15672/api/queues/%2f/celery

Note: Default vhost is / which needs to be escaped as %2f

Using CLI:

$ sudo rabbitmqctl list_queues | grep 'my_queue'

More Related Contents:

  1. What’s a good rate limiting algorithm?
  2. typerror in python while adding value to keys
  3. change value of list in python
  4. Searching for IP addresses in a file
  5. How to make a dict from n’th indices of tuples in list
  6. Split pandas dataframe based on groupby
  7. List comprehension with if statement
  8. Django, creating a custom 500/404 error page
  9. Implement touch using Python?
  10. The difference between sys.stdout.write and print?
  11. Take the content of a list and append it to another list
  12. Why do I get “TypeError: ‘str’ object is not callable” with this code?
  13. What is a cross-platform way to get the home directory?
  14. Error importing scikit-learn modules
  15. Building lxml for Python 2.7 on Windows
  16. Find out how many times a regex matches in a string in Python
  17. Python – How can I pad a string with spaces from the right and left?
  18. List to array conversion to use ravel() function
  19. Drawing a graph or a network from a distance matrix?
  20. Logic Operators in WebDriverWait Expected Conditions
  21. Adding a method to an existing object instance in Python
  22. Launch Pycharm from command line (terminal)
  23. modifying python bytecode
  24. Add single element to array in numpy
  25. How to get the localStorage with Python and Selenium WebDriver
  26. How to parse packets in a python library? [closed]
  27. Limit Python VM memory
  28. Installing lxml for Python 3.4 on Windows x 86 (32 bit) with Visual Studio C++ 2010 Express
  29. Python: type-hinting a classmethod that returns an instance of the class, for a class that is inherited
  30. list comprehension with multiple conditions (python)

Leave a Comment