2

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メッセージを返します。

4

2 に答える 2

1

I have soloved this by adding receiver.capacity = 250. But if I have more messages in the queue and call receiver.available() I recive 250. But it's not a big problem now.

于 2012-06-04T08:19:27.803 に答える