kombu|kombu 如何判断一个 message 是否 acknowledged/requeued/rejected
直接使用 message 的 acknowledged 属性就好了
if not message.acknowledged:
message.ack()
【kombu|kombu 如何判断一个 message 是否 acknowledged/requeued/rejected】当我们使用 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'}
可以看到,已经有三个状态了哦
推荐阅读
- 如何使用Gatsby创建自己的博客
- 2003服务器iis网站在哪,如何在Windows2003系统服务器上安装IIS以及配置Web站
- win10系统如何配置web服务器|win10系统如何配置web服务器,Win10 IIS Web服务器安装与配置
- 投稿|超级主播如何体面退出直播江湖?
- 钛空时间|正确教育孩子真的有这么难吗?如何做一名合格的家长?
- 投稿|如何跨越互联网的寒意
- mysql如何查询是否大小写敏感_MySQL查询大小写是否敏感问题分析
- mysql数据库如何设置大小写不敏感_mysql数据库如何设置表名大小写不敏感?
- 详解如何使用Python实现删除重复文件
- 大健康|商誉压顶、转型不畅,步长制药如何穿过上市“7年之痒”?丨钛媒体深度