diff --git a/internal/server/rds_consume.go b/internal/server/rds_consume.go index 9a888f4..52e2805 100644 --- a/internal/server/rds_consume.go +++ b/internal/server/rds_consume.go @@ -34,14 +34,18 @@ func NewRdbConsumer( manager.Add(cf1) } - if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil { - manager.Add(cf2) - } + //if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil { + // manager.Add(cf2) + //} if cf3 := voucherService.GetRetryNotifyConfig(); cf3 != nil { manager.Add(cf3) } + if cf4 := voucherService.GetOrderNotifyRetryConfig(); cf4 != nil { + manager.Add(cf4) + } + return &RdbConsumer{hLog: hLog, conf: conf, manager: manager} }