order_notify
This commit is contained in:
parent
40f51dd4dd
commit
9e984cdb5a
|
|
@ -34,14 +34,18 @@ func NewRdbConsumer(
|
||||||
manager.Add(cf1)
|
manager.Add(cf1)
|
||||||
}
|
}
|
||||||
|
|
||||||
if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil {
|
//if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil {
|
||||||
manager.Add(cf2)
|
// manager.Add(cf2)
|
||||||
}
|
//}
|
||||||
|
|
||||||
if cf3 := voucherService.GetRetryNotifyConfig(); cf3 != nil {
|
if cf3 := voucherService.GetRetryNotifyConfig(); cf3 != nil {
|
||||||
manager.Add(cf3)
|
manager.Add(cf3)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if cf4 := voucherService.GetOrderNotifyRetryConfig(); cf4 != nil {
|
||||||
|
manager.Add(cf4)
|
||||||
|
}
|
||||||
|
|
||||||
return &RdbConsumer{hLog: hLog, conf: conf, manager: manager}
|
return &RdbConsumer{hLog: hLog, conf: conf, manager: manager}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue