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

如何在 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 条消息。

请您参考如下方法:

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