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) }