From ecb6aa313c5ff25bb250a78aadc43acefb6befc3 Mon Sep 17 00:00:00 2001
From: EpicMo <1982742309@qq.com>
Date: Thu, 31 Aug 2023 22:08:46 +0800
Subject: [PATCH] fix: fix ack

---
 src/services/msgconsumer/main.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/services/msgconsumer/main.go b/src/services/msgconsumer/main.go
index 6db7778..df32d17 100644
--- a/src/services/msgconsumer/main.go
+++ b/src/services/msgconsumer/main.go
@@ -210,7 +210,7 @@ func main() {
 				span.End()
 				continue
 			}
-			err = body.Ack(true)
+			err = body.Ack(false)
 
 			if err != nil {
 				logger.WithFields(logrus.Fields{
@@ -339,7 +339,7 @@ func ss(channel *amqp.Channel) {
 			continue
 		}
 
-		err = body.Ack(true)
+		err = body.Ack(false)
 
 		if err != nil {
 			logger.WithFields(logrus.Fields{