0

キューがあり、そこから n 個の要素を詰め込みました。

そこから 1 つの要素を取得して、コールバックを終了したいと考えていますpika。すべての例でコールバック メカニズムが使用されていますが、これはアプリケーションの構造ではまったく意味がありません。

次のようにコールバックを定義する

def callback(...):
  do_data_thinggs(...)
  exit(0)

メッセージがキューに残っているため、機能しません

これを行うための通常のイディオムは何ですか?

4

2 に答える 2

2

チャネルのbasic_getメソッドを確認し、以下を確認してください。

https://github.com/pika/pika/blob/03542ef616a2a849e8bfb0845427f50e741ea0c6/docs/examples/blocking_basic_get.rstの例では、メッセージが受信されるまでブロックされます。

于 2012-08-07T09:31:27.623 に答える
0

私の理解が正しければ、これはあなたが ACK を返さないことに関係していると思います。このチュートリアルを見てみましょう: RabbitMQ チュートリアル 2

于 2012-08-07T10:12:30.487 に答える