diff --git a/src/nats.ts b/src/nats.ts index 84412e1..f0a04b8 100644 --- a/src/nats.ts +++ b/src/nats.ts @@ -41,7 +41,11 @@ class NatsManager { // Handle connection close events this.nc.closed().then((err) => { - log("ERROR", `NATS: Connection closed: ${err}`); + if (err) { + log("ERROR", `NATS: Connection closed: ${err}`); + } else { + log("INFO", "NATS: Connection ended") + } this.nc = null; this.js = null; this.kv = null;