Merge pull request #5 from prochac/patch-1

Update subscriber.go
ThreeDotsLabs · May 14, 2021 · af17ba1 · af17ba1
2 parents e9b9574 + f191648
commit af17ba1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pkg/amqp/subscriber.go b/pkg/amqp/subscriber.go
@@ -146,8 +146,9 @@ func (s *Subscriber) runSubscriber(
 		return
 	}
 	defer func() {
-		err := channel.Close()
-		s.logger.Error("Failed to close channel", err, logFields)
+		if err := channel.Close(); err != nil {
+			s.logger.Error("Failed to close channel", err, logFields)
+		}
 	}()
 
 	notifyCloseChannel := channel.NotifyClose(make(chan *amqp.Error))