From 5aa86a5497e413742dcd2d6ad16379947f6b0738 Mon Sep 17 00:00:00 2001
From: Fedor Ortyanov <fortyanov@mtt.ru>
Date: Thu, 10 Mar 2022 15:56:56 +0300
Subject: [PATCH] runs consumer reconnection by any rabbit error

---
 channel.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/channel.go b/channel.go
index aee8515..3d66c75 100644
--- a/channel.go
+++ b/channel.go
@@ -59,8 +59,7 @@ func (chManager *channelManager) startNotifyCancelOrClosed() {
 
 	select {
 	case err := <-notifyCloseChan:
-		// If the connection close is triggered by the Server, a reconnection takes place
-		if err != nil && err.Server {
+		if err != nil {
 			chManager.logger.Printf("attempting to reconnect to amqp server after close")
 			chManager.reconnectWithBackoff()
 			chManager.logger.Printf("successfully reconnected to amqp server after close")