如何使用 pika 1.1.0 添加超时？
How to add timeout using pika 1.1.0?
我已经使用 pika 0.12.* 有一段时间了，我习惯于使用以下代码添加超时。
connection = pika.BlockingConnection()
...
connection.add_timeout(30, error)
...
现在我正在迁移以使用 pika 1.1.0，框架中似乎不再存在相同的 add_timeout 功能。
但是，在文档中，我可以找到函数 remove_timeout，它表明我仍然可以在我的代码中添加超时。
是否仍然可以使用 pika 库添加超时？
您应该使用 call_later 方法。它在 1.0.0 版本中从 add_timeout 重命名。
注意： RabbitMQ 团队监控 rabbitmq-users mailing list 并且有时只在 Whosebug 上回答问题。
我已经使用 pika 0.12.* 有一段时间了，我习惯于使用以下代码添加超时。
connection = pika.BlockingConnection()
...
connection.add_timeout(30, error)
...
现在我正在迁移以使用 pika 1.1.0，框架中似乎不再存在相同的 add_timeout 功能。
但是，在文档中，我可以找到函数 remove_timeout，它表明我仍然可以在我的代码中添加超时。
是否仍然可以使用 pika 库添加超时？
您应该使用 call_later 方法。它在 1.0.0 版本中从 add_timeout 重命名。
注意： RabbitMQ 团队监控 rabbitmq-users mailing list 并且有时只在 Whosebug 上回答问题。