From 2f77617718f6e9e41c38cf8b1b00bf93bb1e92c6 Mon Sep 17 00:00:00 2001 From: wagslane Date: Sat, 23 Apr 2022 19:59:02 -0600 Subject: [PATCH] logging --- channel.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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)