From ef822fbb59567de6b529143a97732ee37b18bd2a Mon Sep 17 00:00:00 2001 From: lane-c-wagner Date: Tue, 8 Jun 2021 08:43:47 -0600 Subject: [PATCH] check for nil --- channel.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/channel.go b/channel.go index d63b1c7..2d1340e 100644 --- a/channel.go +++ b/channel.go @@ -59,7 +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.Server { + if err != nil && err.Server { chManager.logger.Printf("attempting to reconnect to amqp server after close") chManager.reconnectWithBackoff() chManager.logger.Printf("successfully reconnected to amqp server after close")