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

ngynwnxp  于 12个月前  发布在  RabbitMQ
关注(0)|答案(1)|浏览(137)

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

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

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

r1wp621o

r1wp621o1#

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

相关问题