pythonのqpidからメッセージの量を取得

Question

qpidライブラリをのpythonでキューに格納されたメッセージの量をどのように受け取ることができますか？

私はこのように試してみました：

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

私は同じ問題に直面しています。しかし私の最後の目標は、キュー内のメッセージを停止して再開することでした。これはあなたを助けるかもしれhttps://qpid.apache.org/releases/qpid-cpp-0.34/cpp-broker/book/producer-flow-control.html

：

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

または、このリンクをチェックしてください。私はこれを見つけました。