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