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

脚本

This commit is contained in:
ziming 2025-08-01 11:53:55 +08:00
parent 0fe1508d9e
commit 6bfd3fe7fd
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/service/retry_notify.go
View File

@ -9,7 +9,7 @@ import (
func (s *VoucherService) GetRetryNotifyConfig() *rdsmq.ConsumeConfig { func (s *VoucherService) GetRetryNotifyConfig() *rdsmq.ConsumeConfig {
queue := s.bc.RdsMQ.GetWechatRetry() queue := s.bc.RdsMQ.GetRetryNotify()
if queue == nil { if queue == nil {
return nil return nil
} }
@ -25,7 +25,7 @@ func (s *VoucherService) GetRetryNotifyConfig() *rdsmq.ConsumeConfig {
NumWorkers: queue.NumWorkers, NumWorkers: queue.NumWorkers,
WaitTime: queue.GetWaitTime().AsDuration(), WaitTime: queue.GetWaitTime().AsDuration(),
RetryNum: queue.RetryNum, RetryNum: queue.RetryNum,
Fn: s.HandleWechatRetry, Fn: s.HandleRetryNotify,
Logger: s.logHelper, Logger: s.logHelper,
} }
} }