From e0863eb04afe185c5b2f242a4410c301496fed3f Mon Sep 17 00:00:00 2001
From: douxu <douxu@clea.com.cn>
Date: Tue, 3 Mar 2026 17:09:31 +0800
Subject: [PATCH] add code of rabbitmq message ack action

---
 event/up_down_limit_alarm.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/event/up_down_limit_alarm.go b/event/up_down_limit_alarm.go
index d2df65f..f4cbd28 100644
--- a/event/up_down_limit_alarm.go
+++ b/event/up_down_limit_alarm.go
@@ -113,6 +113,10 @@ func processAlarmEventMessage(ctx context.Context, msg amqp091.Delivery) {
 		logger.Error(ctx, "failed to insert alarm event into database", "error", err)
 		return
 	}
-	msg.Ack(false)
+	err = msg.Ack(false)
+	if err != nil {
+		logger.Error(ctx, "ack alarm event message failed", "error", err)
+		return
+	}
 	logger.Info(ctx, "alarm event inserted into database", "result", result)
 }