dongmin4990 2017-11-21 07:53
浏览 400
已采纳

RabbitMQ多次确认同一条消息关闭了用户

If I acknowledge the same message twice using the Delivery.Ack method, my consumer channel just closes by itself.

Is this expected behaviour? Has anyone experienced this ?

The reason I am acknowledging the same message twice is a special case where I have to break the original message into copies and process them on the consumer. Once the consumer processes everything, it loops and acks everything. Since there are copies of the entity, it acks the same message twice and my consumer channel shuts down

  • 写回答

1条回答 默认 最新

  • duancan7914 2017-11-21 12:25
    关注

    According to the AMQP reference, a channel exception is raised when a message gets acknowledged for the second time:

    A message MUST not be acknowledged more than once. The receiving peer MUST validate that a non-zero delivery-tag refers to a delivered message, and raise a channel exception if this is not the case.

    Second call to Ack(...) for the same message will not return an error, but the channel gets closed due to this exception received from server:

    Exception (406) Reason: "PRECONDITION_FAILED - unknown delivery tag ?"
    

    It is possible to register a listener via Channel.NotifyClose to observe this exception.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 乘性高斯噪声在深度学习网络中的应用
  • ¥15 运筹学排序问题中的在线排序
  • ¥15 关于docker部署flink集成hadoop的yarn,请教个问题 flink启动yarn-session.sh连不上hadoop,这个整了好几天一直不行,求帮忙看一下怎么解决
  • ¥30 求一段fortran代码用IVF编译运行的结果
  • ¥15 深度学习根据CNN网络模型,搭建BP模型并训练MNIST数据集
  • ¥15 C++ 头文件/宏冲突问题解决
  • ¥15 用comsol模拟大气湍流通过底部加热(温度不同)的腔体
  • ¥50 安卓adb backup备份子用户应用数据失败
  • ¥20 有人能用聚类分析帮我分析一下文本内容嘛
  • ¥30 python代码,帮调试,帮帮忙吧