从python上的qpid获取消息量

Question

如何使用qpid libraryonpython接收存储在队列中的消息量？在

我试过这样做：

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条。但现在不是什么大问题了。在

Answer 2

我一直面临着同样的问题。但我的最后一个目标是停止并恢复队列中的消息。我发现了这个：

qpidd  default-flow-stop-threshold=90  default-flow-resume-threshold=75

或者检查这个链接：https://qpid.apache.org/releases/qpid-cpp-0.34/cpp-broker/book/producer-flow-control.html

这可能对你有帮助。在