From c615570a4a400ecb22d79af926085cba47eda85c Mon Sep 17 00:00:00 2001 From: Fedor Ortyanov Date: Tue, 15 Mar 2022 17:05:28 +0300 Subject: [PATCH] merged with main --- channel.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/channel.go b/channel.go index d869db0..93643fb 100644 --- a/channel.go +++ b/channel.go @@ -68,7 +68,7 @@ func (chManager *channelManager) startNotifyCancelOrClosed() { chManager.notifyCancelOrClose <- err } else if err != nil && err.Reason == "EOF" { chManager.logger.Printf("attempting to reconnect to amqp server after eof") - chManager.reconnectWithBackoff() + chManager.reconnectLoop() chManager.logger.Printf("successfully reconnected to amqp server after eof") chManager.notifyCancelOrClose <- err } else if err != nil {