Log ouput Issues

[cd-home]

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)

worker := server.NewWorker("worker", 0)
worker.Launch()

------ 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

[cd-home]

func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker {
.......
cnf.Broker = strings.Join(ropt.Addrs, ", ")
....
}