publishing log
This commit is contained in:
@@ -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 ""
|
||||
|
||||
Reference in New Issue
Block a user