You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
------ LOG -----------
// LaunchAsync is a non blocking version of Launch
func (worker *Worker) LaunchAsync(errorsChan chan<- error) {
cnf := worker.server.GetConfig()
broker := worker.server.GetBroker()
// Log some useful information about worker configuration
log.INFO.Printf("Launching a worker with the following settings:")
log.INFO.Printf("- Broker: %s", RedactURL(cnf.Broker))
if worker.Queue == "" {
log.INFO.Printf("- DefaultQueue: %s", cnf.DefaultQueue)
} else {
log.INFO.Printf("- CustomQueue: %s", worker.Queue)
}
log.INFO.Printf("- ResultBackend: %s", RedactURL(cnf.ResultBackend))
......
}
in fact, backedn and broker read from conf
The text was updated successfully, but these errors were encountered:
INFO: 2022/05/25 17:52:39 worker.go:58 Launching a worker with the following settings:
INFO: 2022/05/25 17:52:39 worker.go:59 - Broker: ://
INFO: 2022/05/25 17:52:39 worker.go:61 - DefaultQueue: machinery_tasks
INFO: 2022/05/25 17:52:39 worker.go:65 - ResultBackend: ://
INFO: 2022/05/25 17:52:39 goredis.go:110 [*] Waiting for messages. To exit press CTRL+C
TIPS: if use iface mode
cnf := &config.Config{
DefaultQueue: "machinery_tasks",
ResultsExpireIn: 3600,
Redis: &config.RedisConfig{
MaxIdle: 3,
IdleTimeout: 240,
ReadTimeout: 15,
WriteTimeout: 15,
ConnectTimeout: 15,
NormalTasksPollPeriod: 1000,
DelayedTasksPollPeriod: 500,
},
}
broker := redisbroker.NewGR(cnf, []string{"127.0.0.1:6379"}, 0)
backend := redisbackend.NewGR(cnf, []string{"127.0.0.1:6379"}, 0)
lock := eagerlock.New()
server := machinery.NewServer(cnf, broker, backend, lock)
server.RegisterTask("sun", Sum)
------ LOG -----------
// LaunchAsync is a non blocking version of Launch
func (worker *Worker) LaunchAsync(errorsChan chan<- error) {
cnf := worker.server.GetConfig()
broker := worker.server.GetBroker()
......
}
in fact, backedn and broker read from conf
The text was updated successfully, but these errors were encountered: