From 431a4ab367710b0ec0c916ad665efb5df61f55a7 Mon Sep 17 00:00:00 2001
From: Clement <lizi4@huawei.com>
Date: Tue, 30 Aug 2022 16:31:03 +0800
Subject: [PATCH] fix msg blocking

Signed-off-by: Clement <lizi4@huawei.com>
---
 src/gitee-utils/message.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/gitee-utils/message.go b/src/gitee-utils/message.go
index 8c3121a..2401096 100644
--- a/src/gitee-utils/message.go
+++ b/src/gitee-utils/message.go
@@ -7,6 +7,7 @@ import (
 	"io/ioutil"
 	"log"
 	"os"
+	"strings"
 	"time"
 
 	amqp "github.com/rabbitmq/amqp091-go"
@@ -202,6 +203,10 @@ func (c *Consumer) consume(channel *amqp.Channel, id int) {
 	for msg := range msgs {
 		err := eventHandler(msg)
 		if err != nil {
+			errMsg := err.Error()
+			if strings.Contains(errMsg, "404") {
+				msg.Acknowledger.Ack(msg.DeliveryTag, false)
+			}
 			log.Println("something wrong with executor", err)
 		} else {
 			msg.Acknowledger.Ack(msg.DeliveryTag, false)