From 4e82d8db5b02e776ac7764fb8dbbd6fdeca3af37 Mon Sep 17 00:00:00 2001 From: Dmitry Date: Mon, 3 Oct 2022 11:24:53 +0500 Subject: [PATCH] Change error forwarding to logging. --- channel.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/channel.go b/channel.go index 135d68e..e1226db 100644 --- a/channel.go +++ b/channel.go @@ -103,13 +103,12 @@ func (chManager *channelManager) reconnect() error { return err } - err = chManager.channel.Close() - if err != nil { - return err + if err = chManager.channel.Close(); err != nil { + chManager.logger.Warnf("error closing channel while reconnecting: %v", err) } - err = chManager.connection.Close() - if err != nil { - return err + + if err = chManager.connection.Close(); err != nil { + chManager.logger.Warnf("error closing connection while reconnecting: %v", err) } chManager.connection = newConn