goder/bygdata
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change sqs

Browse Source
This commit is contained in:
goder-zhang 2026-02-27 16:05:28 +00:00
parent c1c6bfe6cf
commit 3691cfe8b2
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
api/v1/sqs/aws-sqs.go
View File

@ -201,7 +201,8 @@ func processMessage(svc *sqs.SQS, queueURL string, msg *sqs.Message) {
zap.Int64("receiveCount", receiveCount)) zap.Int64("receiveCount", receiveCount))
// 解析失败时不删除消息，让它自动重新变为可见，实现重复消费 // 解析失败时不删除消息，让它自动重新变为可见，实现重复消费
// 通过将可见性超时设为 0，立即让消息重新变为可见 // 通过将可见性超时设为 0，立即让消息重新变为可见
changeMessageVisibility(svc, queueURL, msg, 0) // changeMessageVisibility(svc, queueURL, msg, 0)
deleteMessage(svc, queueURL, msg)
return return
} }