From 157e79579273c44b65ddfb061af5d51d39eaa90f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Adam=20=C5=A0trauch?= Date: Fri, 31 Dec 2021 08:09:44 +0100 Subject: [PATCH] Invalid NATS connection fix when subscribing to a subject --- nats_driver/main.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/nats_driver/main.go b/nats_driver/main.go index 15d05e1..c6aea58 100644 --- a/nats_driver/main.go +++ b/nats_driver/main.go @@ -55,12 +55,10 @@ func (d *Driver) Init() error { return fmt.Errorf("please initiate LogChannel variable") } - var nc *nats.Conn - for { nc, err := nats.Connect(d.NATSUrl) if err != nil { - log.Println("Can't connect to the NATS server, waiting for 5 seconds before I try it again.") + log.Printf("Can't connect to the NATS server, waiting for 5 seconds before I try it again. (%v)\n", err) time.Sleep(time.Second * 5) continue } @@ -68,9 +66,9 @@ func (d *Driver) Init() error { break } - _, err := nc.Subscribe(d.NATSDiscoveryChannel, d.handler) + _, err := d.nc.Subscribe(d.NATSDiscoveryChannel, d.handler) if err != nil { - return err + return fmt.Errorf("subscribe error: %v", err) } return nil