diff --git a/tools/nats_caller.go b/tools/nats_caller.go index 2e477c9..94c23ba 100644 --- a/tools/nats_caller.go +++ b/tools/nats_caller.go @@ -116,9 +116,11 @@ func (o *natsCaller) SetNATSPub(method NATSMethod, data NATSResponse) string { } err = nc.Publish(method.GenerateKey(), js) // Publish the message on the NATS server with a channel name based on the data name (or whatever start) and the method if err != nil { + fmt.Println("Publish Failed", err) time.Sleep(1 * time.Minute) continue } + fmt.Println("Published on", method.GenerateKey()) break } return ""