Actually set insecure if not using AMQPS

This commit is contained in:
Roland Shoemaker 2016-02-29 12:20:17 -08:00
parent e5d3e9a1bc
commit 1e7a2e7003
1 changed files with 2 additions and 1 deletions

View File

@ -159,8 +159,9 @@ func main() {
},
}
if *amqpCert != "" && *amqpKey != "" && *amqpCA != "" {
amqpConf.Insecure = false
amqpConf.TLS = &cmd.TLSConfig{CertFile: amqpCert, KeyFile: amqpKey, CACertFile: amqpCA}
} else {
amqpConf.Insecure = true
}
cmd.FailOnError(err, "Failed to read db URI")
b, err := new(