add code of rabbitmq message ack action

2026-03-03 17:09:31 +08:00 · 2026-03-03 17:09:31 +08:00 · e0863eb04a
parent 609511c7cd
commit e0863eb04a
1 changed files with 5 additions and 1 deletions
--- 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)
 }