From 6a1168967f1e3a678a23566b75599dbbc538c25b Mon Sep 17 00:00:00 2001 From: Dmitry Date: Sun, 24 Jul 2022 20:08:50 +0300 Subject: [PATCH] Add handle errors on channel closing while reconnecting. --- channel.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/channel.go b/channel.go index 62122ea..135d68e 100644 --- a/channel.go +++ b/channel.go @@ -103,8 +103,14 @@ func (chManager *channelManager) reconnect() error { return err } - chManager.channel.Close() - chManager.connection.Close() + err = chManager.channel.Close() + if err != nil { + return err + } + err = chManager.connection.Close() + if err != nil { + return err + } chManager.connection = newConn chManager.channel = newChannel