Количество сообщений в очереди

[rkablukov]

Очень нужна функция, которая вернёт количество сообщений в очереди.
Будет полезна, чтобы сориентироваться сколько воркеров запускать для получения сообщений.

[korableg]

Это у зайца в апи есть

[bugaga45]

Метод declareQueue может отдавать количество сообщений в очереди, но в компоненте эта возможность почему-то не используется.

Из описания метода в amqpcpp\channel.h:

*  For example: channel.declareQueue("myqueue").onSuccess([](const std::string &name, uint32_t messageCount, uint32_t consumerCount) {
*
*      std::cout << "Queue '" << name << "' has been declared with " << messageCount << " messages and " << consumerCount << " consumers" << std::endl;
*
*  });

[bafgion]

Здравствуйте!

В v2.6.0.17 добавлен метод GetQueueMessageCount(ИмяОчереди) — возвращает число сообщений в очереди (через passive declare).

PR #109 · сборка:
https://github.com/bafgion/PinkRabbitMQ/releases/tag/prmq_17

С уважением,
@bafgion