Skip to content

Commit bda902b

Browse files
committed
remove unused vars
1 parent 56ab088 commit bda902b

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

pkg/outputs/nats_outputs/jetstream/jetstream_output.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -490,7 +490,7 @@ func (n *jetstreamOutput) createNATSConn(c *config) (*nats.Conn, error) {
490490
nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) {
491491
n.logger.Printf("NATS error: %v", err)
492492
}),
493-
nats.DisconnectErrHandler(func(c *nats.Conn, err error) {
493+
nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
494494
n.logger.Printf("Disconnected from NATS err=%v", err)
495495
}),
496496
nats.ClosedHandler(func(*nats.Conn) {

pkg/outputs/nats_outputs/nats/nats_output.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,7 @@ func (n *NatsOutput) createNATSConn(c *Config) (*nats.Conn, error) {
269269
nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) {
270270
n.logger.Printf("NATS error: %v", err)
271271
}),
272-
nats.DisconnectErrHandler(func(c *nats.Conn, err error) {
272+
nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
273273
n.logger.Printf("Disconnected from NATS err=%v", err)
274274
}),
275275
nats.ClosedHandler(func(*nats.Conn) {

0 commit comments

Comments
 (0)