rabbitpy

3熱

1答えて

rabbitpyメッセージループは大量のメモリを消費するようです

例に見られるような標準的な手順（forループ）を使用して、マシンに使用されているメモリが大量にあります。私。キュー内のすべてのメッセージがメモリにロードされ、確認応答されたように見えます。このアプローチはhereです。キューはジェネレータであると仮定しました。 import rabbitpy with rabbitpy.Connection('amqp://guest:[email prote

python rabbitpy 2017-01-31

---

0熱

1答えて

Rabbitpyリスナー間違ったキューからの読み込み

rabbitpyを使用するプログラムを実行しようとすると、あるキューのターミナルからコマンドを送信し、別のキューの別のスレッドで応答を読み込みます。問題は、queue1でメッセージを送信すると、リスナー・スレッド（queue1ではなくqueue2で待機している必要があります）がqueue1からメッセージを読み込み/消費することです。以下は私のコードです。すべての大文字の定数は文字列定数だけであり、

python-2.7 rabbitmq rabbitpy 2017-05-17

---