Browse Source

check for nil

pull/25/head v0.6.1
lane-c-wagner 5 years ago
parent
commit
ef822fbb59
1 changed files with 1 additions and 1 deletions
  1. +1
    -1
      channel.go

+ 1
- 1
channel.go View File

@ -59,7 +59,7 @@ func (chManager *channelManager) startNotifyCancelOrClosed() {
select { select {
case err := <-notifyCloseChan: case err := <-notifyCloseChan:
// If the connection close is triggered by the Server, a reconnection takes place // If the connection close is triggered by the Server, a reconnection takes place
if err.Server {
if err != nil && err.Server {
chManager.logger.Printf("attempting to reconnect to amqp server after close") chManager.logger.Printf("attempting to reconnect to amqp server after close")
chManager.reconnectWithBackoff() chManager.reconnectWithBackoff()
chManager.logger.Printf("successfully reconnected to amqp server after close") chManager.logger.Printf("successfully reconnected to amqp server after close")


Loading…
Cancel
Save