소스 검색

allow user/password on non-tls connections

Tobias Begalke 6 년 전
부모
커밋
9f2f5e55b8
1개의 변경된 파일5개의 추가작업 그리고 1개의 파일을 삭제
  1. 5 1
      main.go

+ 5 - 1
main.go

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