Browse Source

Merge branch 'main' into simpler_bindings

# Conflicts:
#	channel.go
pull/81/head
christoph.haas 3 years ago
parent
commit
2447aaa805
1 changed files with 7 additions and 2 deletions
  1. +7
    -2
      channel.go

+ 7
- 2
channel.go View File

@ -103,8 +103,13 @@ func (chManager *channelManager) reconnect() error {
return err
}
_ = chManager.channel.Close()
_ = chManager.connection.Close()
if err = chManager.channel.Close(); err != nil {
chManager.logger.Warnf("error closing channel while reconnecting: %v", err)
}
if err = chManager.connection.Close(); err != nil {
chManager.logger.Warnf("error closing connection while reconnecting: %v", err)
}
chManager.connection = newConn
chManager.channel = newChannel


Loading…
Cancel
Save