3
0
dongzhaorui 1 жил өмнө
parent
commit
fb7fe96f29

+ 1 - 1
FworkSpider/feapder/db/rabbitMq.py

@@ -416,7 +416,7 @@ class RabbitMQ:
             body = tools.loads_obj(message.body)  # 反序列化消息对象
             delivery_tag = message.delivery_tag
             if auto_ack:
-                self._channel.basic.ack(delivery_tag)
+                self.ack(delivery_tag)
                 delivery_tag = 0
 
             if to_str: