From d094dbd5ffac56f67d026498343e6849d5c3a6ab Mon Sep 17 00:00:00 2001
From: ziming <zi__mm@163.com>
Date: Tue, 10 Jun 2025 10:17:16 +0800
Subject: [PATCH] query

---
 internal/pkg/rdsmq/rdsmq.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/internal/pkg/rdsmq/rdsmq.go b/internal/pkg/rdsmq/rdsmq.go
index 3ef5b7c..6712883 100644
--- a/internal/pkg/rdsmq/rdsmq.go
+++ b/internal/pkg/rdsmq/rdsmq.go
@@ -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)
 	}