超时无法通过 pika 发送。阻塞连接答案

【问题标题】：Timeout is not able to sent via pika.Blocking connection超时无法通过 pika 发送。阻塞连接
【发布时间】：2012-04-27 12:24:26
【问题描述】：

我正在尝试编写一个从 rabbitmq 服务器接收的客户端程序，我想用它来设置超时。在指定的时间之后，客户端应该停止消费队列中的消息并退出。

我正在使用带有阻塞连接的鼠兔。我看到了阻塞连接中定义的 add_timeout(delay,callback) ，但是当我尝试使用它时，我收到以下错误。

 [*] 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()

如果我在指定的超时期限内收到消息，客户端应该打印消息并且应该停止进一步消费。

谁能帮我在客户端设置超时时间？

【问题讨论】：

标签： python pika

【解决方案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,)

【讨论】：