lint: in the shadow of errs

anycable · Nov 2, 2023 · 46fcd1b · 46fcd1b
1 parent b5b97c2
commit 46fcd1b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/broker/nats.go b/broker/nats.go
@@ -364,7 +364,7 @@ func (n *NATS) addStreamConsumer(stream string) {
 createConsumer:
 	prefixedStream := streamPrefix + stream
 
-	_, err = n.jconsumers.fetch(stream, func() (jetstream.Consumer, error) { // nolint:errcheck
+	_, cerr := n.jconsumers.fetch(stream, func() (jetstream.Consumer, error) { // nolint:errcheck
 		cons, err := n.js.CreateConsumer(context.Background(), prefixedStream, jetstream.ConsumerConfig{
 			AckPolicy: jetstream.AckNonePolicy,
 		})
@@ -411,8 +411,8 @@ createConsumer:
 		n.js.DeleteConsumer(context.Background(), prefixedStream, name) // nolint:errcheck
 	})
 
-	if err != nil {
-		if context.DeadlineExceeded == err {
+	if cerr != nil {
+		if context.DeadlineExceeded == cerr {
 			if attempts > 0 {
 				attempts--
 				n.log.Warnf("failed to create consumer for stream %s, retrying in 500ms...", stream)