Browse Source

Change error forwarding to logging.

pull/83/head
Dmitry 3 years ago
parent
commit
4e82d8db5b
1 changed files with 5 additions and 6 deletions
  1. +5
    -6
      channel.go

+ 5
- 6
channel.go View File

@ -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


Loading…
Cancel
Save