小编Rap*_*oux的帖子

Rabbitmq Consumer_Timeout 行为未按预期工作?

我很难证明该consumer_timeout设置按预期工作。我可能做错了或者误解了consumer_timeout行为。

我所有的测试代码都可以在这里找到:https ://github.com/Rafarel/rabbitmq-tests

基本上,我将时间consumer_timeout设置为 10000 毫秒(10 秒),然后尝试通过回调来消耗该消息,该回调的睡眠时间比超时值(20 秒)长一点,然后再尝试确认该消息。

由于超时,我应该有一个 PRECONDITION_FAILED 异常,但事实并非如此。如果我设置的SLEEP_DURATION方式receive_timeout.pyconsumer_timeout60 秒之类的值,

引用自https://www.rabbitmq.com/consumers.html#acknowledgement-timeout

如果消费者在超过超时值(默认为 30 分钟)的时间内没有确认其交付,则其通道将被关闭,并出现 PRECONDITION_FAILED 通道异常。

如果有人可以帮助我理解我做错了什么,那就太好了,谢谢!

python timeout rabbitmq pika

9
推荐指数
2
解决办法
1万
查看次数

标签 统计

pika ×1

python ×1

rabbitmq ×1

timeout ×1