liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

query

This commit is contained in:
ziming 2025-06-10 10:17:16 +08:00
parent 4639e6a347
commit d094dbd5ff
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/pkg/rdsmq/rdsmq.go
View File

@ -89,11 +89,13 @@ func (r *ConsumeConfig) Start(ctx context.Context) {
}
func (r *ConsumeConfig) consumer(ctx context.Context, queueName string, value string) {
if err := r.Fn(ctx, value); err == nil {
r.Logger.Errorf("BLPop on %s Failed to process message [%s] after retry %d times, err[%v]\n", queueName, value, r.RetryNum, err)
err := r.Fn(ctx, value)
if err == nil {
return
}
r.Logger.Errorf("BLPop on %s Failed to process message [%s] after retry %d times, err[%v]\n", queueName, value, r.RetryNum, err)
if r.RetryNum > 0 {
r.retry(ctx, queueName, value)
}