如何使用pika 1.1.0添加超时?

问题描述 投票:0回答:1

我使用pika 0.12。*已经有一段时间了,我习惯于使用以下代码来添加超时。

connection = pika.BlockingConnection()
...
connection.add_timeout(30, error)
...

现在我正在迁移使用pika 1.1.0,该框架中似乎不再存在相同的add_timeout函数。

但是,在文档中,我可以找到函数remove_timeout,该函数表明我仍然可以向代码添加超时。是否仍然可以使用pika lib添加超时?

rabbitmq pika
1个回答
0
投票

您应使用call_later方法。它在add_timeout版本中从1.0.0重命名。


[NOTE: RabbitMQ团队监视rabbitmq-users mailing list,并且有时仅在StackOverflow上回答问题。

© www.soinside.com 2019 - 2024. All rights reserved.