|
@@ -154,7 +154,7 @@ func main() {
|
|
if config.NatsUser != "" && config.NatsPassword != "" && config.NatsCA != "" {
|
|
if config.NatsUser != "" && config.NatsPassword != "" && config.NatsCA != "" {
|
|
natsConn, err = nats.Connect(config.NatsURL, nats.UserInfo(config.NatsUser, config.NatsPassword), nats.RootCAs(config.NatsCA))
|
|
natsConn, err = nats.Connect(config.NatsURL, nats.UserInfo(config.NatsUser, config.NatsPassword), nats.RootCAs(config.NatsCA))
|
|
} else {
|
|
} else {
|
|
- if config.NatsPassword != "" && config.NatsCA != "" {
|
|
|
|
|
|
+ if config.NatsPassword != "" && config.NatsUser != "" {
|
|
natsConn, err = nats.Connect(config.NatsURL, nats.UserInfo(config.NatsUser, config.NatsPassword))
|
|
natsConn, err = nats.Connect(config.NatsURL, nats.UserInfo(config.NatsUser, config.NatsPassword))
|
|
} else {
|
|
} else {
|
|
natsConn, err = nats.Connect(config.NatsURL)
|
|
natsConn, err = nats.Connect(config.NatsURL)
|