|
|
@ -72,7 +72,7 @@ func (chManager *channelManager) startNotifyCancelOrClosed() { |
|
|
chManager.logger.Printf("successfully reconnected to amqp server after eof") |
|
|
chManager.logger.Printf("successfully reconnected to amqp server after eof") |
|
|
chManager.notifyCancelOrClose <- err |
|
|
chManager.notifyCancelOrClose <- err |
|
|
} else if err != nil { |
|
|
} else if err != nil { |
|
|
chManager.logger.Printf("not attempting to reconnect to amqp server because closure was initiated by the client") |
|
|
|
|
|
|
|
|
chManager.logger.Printf("not attempting to reconnect to amqp server because closure was initiated by the client: %v", err) |
|
|
} else if err == nil { |
|
|
} else if err == nil { |
|
|
chManager.logger.Printf("amqp channel closed gracefully") |
|
|
chManager.logger.Printf("amqp channel closed gracefully") |
|
|
} |
|
|
} |
|
|
|