From 6bfd3fe7fd0a91d1b230477caada2eb3e2baa0f6 Mon Sep 17 00:00:00 2001
From: ziming <zi__mm@163.com>
Date: Fri, 1 Aug 2025 11:53:55 +0800
Subject: [PATCH] =?UTF-8?q?=E8=84=9A=E6=9C=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/service/retry_notify.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/service/retry_notify.go b/internal/service/retry_notify.go
index f059ee2..ac8c476 100644
--- a/internal/service/retry_notify.go
+++ b/internal/service/retry_notify.go
@@ -9,7 +9,7 @@ import (
 
 func (s *VoucherService) GetRetryNotifyConfig() *rdsmq.ConsumeConfig {
 
-	queue := s.bc.RdsMQ.GetWechatRetry()
+	queue := s.bc.RdsMQ.GetRetryNotify()
 	if queue == nil {
 		return nil
 	}
@@ -25,7 +25,7 @@ func (s *VoucherService) GetRetryNotifyConfig() *rdsmq.ConsumeConfig {
 		NumWorkers: queue.NumWorkers,
 		WaitTime:   queue.GetWaitTime().AsDuration(),
 		RetryNum:   queue.RetryNum,
-		Fn:         s.HandleWechatRetry,
+		Fn:         s.HandleRetryNotify,
 		Logger:     s.logHelper,
 	}
 }