fix: fix ack

GuGoOrg · Aug 31, 2023 · ecb6aa3 · ecb6aa3
1 parent 684d05b
commit ecb6aa3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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{