RabbitMQ Pika - как проверить, активен ли потребитель

Question

Кто-нибудь знает, как проще всего проверить, активен ли потребитель для определенной очереди?Я мог бы вручную запустить API на localhost, но мне бы хотелось, чтобы это делалось с Пикой.

Например, у меня есть очередь xyz Я хочу знать, сколько потребителей слушают эту очередь.

Answer 1

Вы можете сделать queue.declare с passive=true для той же очереди, из которой вы хотите получить количество потребителей.Это вернет ответ (queue.declare-ok), который включает в себя счетчик потребителя .

С справочная документация протокола :

бит пассивный

Если установлено, сервер ответит объявлением-ОК, если очередь уже существует с таким именем, и выдаст ошибку, если нет.Клиент может использовать это для проверки существования очереди без изменения состояния сервера.