diff --git a/channel.go b/channel.go index b353989..7f4479a 100644 --- a/channel.go +++ b/channel.go @@ -61,7 +61,7 @@ func (chManager *channelManager) startNotifyCancelOrClosed() { select { case err := <-notifyCloseChan: if err != nil { - chManager.logger.Printf("attempting to reconnect to amqp server from error: %v", err) + chManager.logger.Printf("attempting to reconnect to amqp server after close with error: %v", err) chManager.reconnectLoop() chManager.logger.Printf("successfully reconnected to amqp server") chManager.notifyCancelOrClose <- err @@ -70,7 +70,7 @@ func (chManager *channelManager) startNotifyCancelOrClosed() { chManager.logger.Printf("amqp channel closed gracefully") } case err := <-notifyCancelChan: - chManager.logger.Printf("attempting to reconnect to amqp server after cancel") + chManager.logger.Printf("attempting to reconnect to amqp server after cancel with error: %s", err) chManager.reconnectLoop() chManager.logger.Printf("successfully reconnected to amqp server after cancel") chManager.notifyCancelOrClose <- errors.New(err)