python - 在 python 上从 qpid 获取消息量

Question

如何在 python 上使用 qpid 库 接收存储在队列中的消息数量？

我试过这样的:

from qpid.messaging import *

broker_rcv = connect_address 
address_rcv = queue_name  + "; { node: { type: queue }, assert: never , create: never, mode: " + "browse" + " }"
connection_rcv = Connection(broker_rcv)
connection_rcv.open()
session_rcv = connection_rcv.session()
receiver = session_rcv.receiver(address_rcv)
print receiver.available()

它总是返回 0 条消息。

Answer 1

我通过添加 receiver.capacity = 250 解决了这个问题。但是，如果队列中有更多消息并调用 receiver.available()，我会收到 250。但现在这不是什么大问题。