【发布时间】:2020-11-11 01:09:38
【问题描述】:
在 RabbitMQ Web UI 中,我可以看到,对于每个队列,准备好使用的消息数以及正在处理但尚未确认的消息数。
但是,我看不到如何通过 AMQP 客户端获取未确认消息的数量。
例如,AMQP.Queue.message_count/2 function in the Elixir client 使用 the underlying Erlang library 使用 passive: true 重新声明队列并返回 message_count 和 consumer_count 字段,但 message_count 仅包含“准备好传递”的消息(例如,不等待确认)”。
我的目标是查看我目前有多少积压的消息。就我而言,目前正在处理的那些只是那些准备好处理的部分。
如何使用 AMQP 客户端获取给定 RabbitMQ 队列的未确认消息计数?
【问题讨论】:
标签: rabbitmq erlang elixir amqp