From bda902be57b247ec28d4d3dbe253d2338a00ba6d Mon Sep 17 00:00:00 2001 From: Karim Radhouani Date: Thu, 7 Nov 2024 08:35:49 -0800 Subject: [PATCH] remove unused vars --- pkg/outputs/nats_outputs/jetstream/jetstream_output.go | 2 +- pkg/outputs/nats_outputs/nats/nats_output.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/outputs/nats_outputs/jetstream/jetstream_output.go b/pkg/outputs/nats_outputs/jetstream/jetstream_output.go index 34428d45..a7e2efad 100644 --- a/pkg/outputs/nats_outputs/jetstream/jetstream_output.go +++ b/pkg/outputs/nats_outputs/jetstream/jetstream_output.go @@ -490,7 +490,7 @@ func (n *jetstreamOutput) createNATSConn(c *config) (*nats.Conn, error) { nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) { n.logger.Printf("NATS error: %v", err) }), - nats.DisconnectErrHandler(func(c *nats.Conn, err error) { + nats.DisconnectErrHandler(func(_ *nats.Conn, err error) { n.logger.Printf("Disconnected from NATS err=%v", err) }), nats.ClosedHandler(func(*nats.Conn) { diff --git a/pkg/outputs/nats_outputs/nats/nats_output.go b/pkg/outputs/nats_outputs/nats/nats_output.go index 4f943a6a..407765d9 100644 --- a/pkg/outputs/nats_outputs/nats/nats_output.go +++ b/pkg/outputs/nats_outputs/nats/nats_output.go @@ -269,7 +269,7 @@ func (n *NatsOutput) createNATSConn(c *Config) (*nats.Conn, error) { nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) { n.logger.Printf("NATS error: %v", err) }), - nats.DisconnectErrHandler(func(c *nats.Conn, err error) { + nats.DisconnectErrHandler(func(_ *nats.Conn, err error) { n.logger.Printf("Disconnected from NATS err=%v", err) }), nats.ClosedHandler(func(*nats.Conn) {