Update to support tls config options
This commit is contained in:
parent
bf60028cf1
commit
96937ae487
1
nats.go
1
nats.go
@ -68,6 +68,7 @@ func (n *nbroker) Connect() error {
|
|||||||
opts := nats.DefaultOptions
|
opts := nats.DefaultOptions
|
||||||
opts.Servers = n.addrs
|
opts.Servers = n.addrs
|
||||||
opts.Secure = n.opts.Secure
|
opts.Secure = n.opts.Secure
|
||||||
|
opts.TLSConfig = n.opts.TLSConfig
|
||||||
|
|
||||||
c, err := opts.Connect()
|
c, err := opts.Connect()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user