Bind external configuration

This commit is contained in:
Mario
2022-06-02 12:17:18 +02:00
parent 24b85bb28b
commit e980c7509a
4 changed files with 3 additions and 5 deletions

View File

@ -30,11 +30,9 @@ func main() {
if coreConfigurations.Core.Tracing.RabbitMQEnabled {
rabbitMQURI, configured := os.LookupEnv("RABBITMQ_URI")
log.Info(rabbitMQURI)
if !configured {
rabbitMQURI = coreConfigurations.Core.Tracing.RabbitMQURI
}
log.Info(rabbitMQURI)
conn, err := amqp.Dial(rabbitMQURI)
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()