rabbitmq 如何使用pika 1.1.0添加超时？

ngynwnxp 于 2023-10-20 发布在 RabbitMQ

关注(0)|答案(1)|浏览(154)

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

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

现在我正在迁移到使用pika 1.1.0，相同的add_timeout函数似乎不再存在于框架中。
然而，在文档中，我可以找到函数remove_timeout，这表明我仍然可以在代码中添加超时。是否仍然可以使用pika lib添加超时？

1条答案

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