タイムアウトをpika.Blocking接続経由で送信することができません

Question

タイムアウトを設定するrabbitmqサーバから受信するクライアントプログラムを作成しようとしています。指定した時間が経過すると、クライアントはキューからメッセージを消費して終了する必要があります。

私はブロッキング接続でピカを使用しています。私は、ブロック接続で定義されたadd_timeout（遅延、コールバック）を見ましたが、私がそれを使用しようとしているとき、次のエラーが発生しています。

[*] Waiting for logs. To exit press CTRL+C 
Traceback (most recent call last): 
    File "/root/workspace/Misc/misc/pika_samples/log_recieve.py", line 39, in <module> 
    channel.start_consuming() 
    File "/usr/lib/python2.6/site-packages/pika/adapters/blocking_connection.py", line 293, in start_consuming 
    self.transport.connection.process_data_events() 
    File "/usr/lib/python2.6/site-packages/pika/adapters/blocking_connection.py", line 103, in process_data_events 
    self.process_timeouts() 
    File "/usr/lib/python2.6/site-packages/pika/adapters/blocking_connection.py", line 160, in process_timeouts 
    self._timeouts[timeout_id]['handler']() 
TypeError: callback() takes exactly 4 arguments (0 given) 

これは私のクライアントプログラムです。私は、タイムアウト状態をシミュレートするためのサーバーを実行していません。

#!/usr/bin/env python 
import pika 
import sys 

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) 
channel = connection.channel() 
channel.exchange_declare(exchange='topic_logs',type='topic') 
result = channel.queue_declare(exclusive=True) 
queue_name = result.method.queue 
binding_keys = "#" 
for binding_key in binding_keys: 
    channel.queue_bind(exchange='topic_logs',queue=queue_name, 
        routing_key=binding_key) 

print ' [*] Waiting for logs. To exit press CTRL+C' 
def callback(ch, method, properties, body): 
    print " [x] %r:%r" % (method.routing_key, body,) 
    channel.stop_consuming() 
connection.add_timeout(10, callback) 
channel.basic_consume(callback,queue=queue_name,no_ack=True) 
channel.start_consuming() 

---

私が入った場合は、タイムアウト期間指定されたクライアント内のメッセージは、メッセージを印刷するようになっていると、さらにかかる停止する必要があります。

クライアントでタイムアウトを設定する方法を教えてもらえますか？

Answer 1

この期限内の問題です。その後、デッドラインの瞬間は、引数なしで呼び出される関数コールバックとなります。コードを変更することができます。

def callback(ch=None, method=None, properties=None, body=None): 
    if ch is None or method is None or properties is None or body is None: 
     print "Deadline" 
    else: 
     print " [x] %r:%r" % (method.routing_key, body,)