关于python:kombu-如何判断一个-message-是否-acknowledgedrequeuedrejected

间接应用 message 的 acknowledged 属性就好了

if not message.acknowledged:
    message.ack()

当咱们应用 acknowledged 的时候,其实干的是上面的事件:

kombu/message.py

@property
def acknowledged(self):
    """Set to true if the message has been acknowledged."""
    return self._state in ACK_STATES

ACK_STATES 是什么呢?

kombu/message.py

ACK_STATES = {'ACK', 'REJECTED', 'REQUEUED'}

能够看到,曾经有三个状态了哦

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理