如何将来自 GoWorkers ( docs )的日志存储到文件中。我表明有一个WorkersLogger界面,但我不明白如何使用它。
目前我有这个:
func main() {
workers.Configure(map[string]string)
workers.Middleware.Append(&midRetry{})
workers.Process("imp", worker.InitJob, 30)
workers.Run()
}
type midRetry struct{}
func (r *midRetry) Call(queue string, message *workers.Msg, next func() bool) (acknowledge bool) {
acknowledge = next()
return
}
我想在chan stringmidRetry结构体中创建一个,并在Call内部通道上发送消息,并在main中接收它们,然后将它们写入文件,但我觉得有更好的方法。
相关分类