Catch error on startup about machinery HOT 4 CLOSED

func (worker *Worker) Launch() error {
    cnf := worker.server.GetConfig()
    broker := worker.server.GetBroker()

    log.Printf("Launching a worker with the following settings:")
    log.Printf("- Broker: %s", cnf.Broker)
    log.Printf("- ResultBackend: %s", cnf.ResultBackend)
    log.Printf("- Exchange: %s", cnf.Exchange)
    log.Printf("- ExchangeType: %s", cnf.ExchangeType)
    log.Printf("- DefaultQueue: %s", cnf.DefaultQueue)
    log.Printf("- BindingKey: %s", cnf.BindingKey)

    errorsChan := make(chan error)

    go func() {
        for {
            retry, err := broker.StartConsuming(worker.ConsumerTag, worker)
            if err != nil {
                errorsChan <- err
            }

            if retry {
                log.Printf("Going to retry launching the worker. Error: %v", err)
            }
        }
    }()

    return <-errorsChan
}