From 3691cfe8b298d9f97b0e405b408605ee5359c82a Mon Sep 17 00:00:00 2001 From: goder-zhang Date: Fri, 27 Feb 2026 16:05:28 +0000 Subject: [PATCH] change sqs --- api/v1/sqs/aws-sqs.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/api/v1/sqs/aws-sqs.go b/api/v1/sqs/aws-sqs.go index 20ff78d..b0a0b9b 100644 --- a/api/v1/sqs/aws-sqs.go +++ b/api/v1/sqs/aws-sqs.go @@ -201,7 +201,8 @@ func processMessage(svc *sqs.SQS, queueURL string, msg *sqs.Message) { zap.Int64("receiveCount", receiveCount)) // 解析失败时不删除消息,让它自动重新变为可见,实现重复消费 // 通过将可见性超时设为 0,立即让消息重新变为可见 - changeMessageVisibility(svc, queueURL, msg, 0) + // changeMessageVisibility(svc, queueURL, msg, 0) + deleteMessage(svc, queueURL, msg) return }