0

我有一个 Qpid Proton PythonMessageHandler接收一些触发一些处理的消息。如果处理失败,我如何拒绝消息?据我从 API 文档中可以看出,默认值为auto_accept=True. 但是,将其更改为False似乎并不能避免确认消息,因为后续接收者没有赶上失败的消息。

4

1 回答 1

1

如果您禁用自动接受,明确接受或拒绝消息是您的责任。如果您两者都不做,则消息将陷入困境。

这是执行显式确认的应用程序代码示例:

def on_message(self, event):
    try:
        process_message(event.message)
        event.delivery.update(ACCEPTED)
    except:
        event.delivery.update(REJECTED)
于 2021-01-29T10:51:21.303 回答