Browse Source

Add handle errors on channel closing while reconnecting.

pull/83/head
Dmitry 3 years ago
parent
commit
6a1168967f
1 changed files with 8 additions and 2 deletions
  1. +8
    -2
      channel.go

+ 8
- 2
channel.go View File

@ -103,8 +103,14 @@ func (chManager *channelManager) reconnect() error {
return err 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.connection = newConn
chManager.channel = newChannel chManager.channel = newChannel


Loading…
Cancel
Save