prdUploader/pkg/async/async.go

18 lines
294 B

1 month ago
package async
import "epur-pay/pkg/mq"
var Asyncs *AsyncsModel
func New() {
Asyncs = &AsyncsModel{}
Asyncs.AfterCallback = &Async{
Run: AfterCallbackProducer,
Name: "afterCallback",
}
mq.AysncInstance.
Consumer(Asyncs.AfterCallback.Name, AfterCallback, 1) //接口After调用
}