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