Add more defaultNatsOptions and change log msgs

imperiuse · Feb 17, 2021 · 0a1829d · 0a1829d
1 parent e269347
commit 0a1829d
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/nats/client.go b/nats/client.go
@@ -137,13 +137,16 @@ func (c *client) defaultNatsOptions() []Option {
 		nats.ReconnectJitter(ReconnectJitterDefault, ReconnectJitterTLSDefault),
 		nats.ReconnectWait(ReconnectWaitDefault),
 		nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
-			c.log.Warn("Got disconnected", zap.Error(err))
+			c.log.Warn("[DisconnectErrHandler] Disconnect", zap.Error(err))
 		}),
 		nats.ReconnectHandler(func(nc *nats.Conn) {
-			c.log.Warn("Got reconnected", zap.String("ConnUrl", nc.ConnectedUrl()))
+			c.log.Warn("[ReconnectHandler] Reconnect", zap.String("ConnUrl", nc.ConnectedUrl()))
 		}),
 		nats.ClosedHandler(func(nc *nats.Conn) {
-			c.log.Warn("Connection closed", zap.Error(nc.LastError()))
+			c.log.Warn("[ClosedHandler] Close handler", zap.Error(nc.LastError()))
+		}),
+		nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) {
+			c.log.Warn("[ErrorHandler]", zap.Error(err))
 		}),
 	}
 }