BITERP / PinkRabbitMQ

Внешняя Native API компонента для взаимодействия с RabbitMQ из 1С
MIT License
264 stars 107 forks source link

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

Open rkablukov opened 2 years ago

rkablukov commented 2 years ago

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

korableg commented 2 years ago

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

bugaga45 commented 1 year ago

Метод 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;
*
*  });