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 {