From d09cbe2ba23d947f5f2826efa02b917ca57424de Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Fri, 29 Apr 2022 13:48:50 +0200 Subject: [PATCH] add more debug logs Signed-off-by: Valery Piashchynski --- amqpjobs/redial.go | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/amqpjobs/redial.go b/amqpjobs/redial.go index 81ccd50..233c808 100644 --- a/amqpjobs/redial.go +++ b/amqpjobs/redial.go @@ -18,6 +18,7 @@ func (c *Consumer) redialer() { //nolint:gocognit,gocyclo select { case err := <-c.notifyCloseConnCh: if err == nil { + c.log.Debug("exited from redialer") return } @@ -29,13 +30,16 @@ func (c *Consumer) redialer() { //nolint:gocognit,gocyclo select { case c.redialCh <- err: + c.log.Debug("exited from redialer") return default: + c.log.Debug("exited from redialer") return } case err := <-c.notifyCloseConsumeCh: if err == nil { + c.log.Debug("exited from redialer") return } @@ -47,12 +51,15 @@ func (c *Consumer) redialer() { //nolint:gocognit,gocyclo select { case c.redialCh <- err: + c.log.Debug("exited from redialer") return default: + c.log.Debug("exited from redialer") return } case err := <-c.notifyClosePubCh: if err == nil { + c.log.Debug("exited from redialer") return } @@ -64,12 +71,15 @@ func (c *Consumer) redialer() { //nolint:gocognit,gocyclo select { case c.redialCh <- err: + c.log.Debug("exited from redialer") return default: + c.log.Debug("exited from redialer") return } case err := <-c.notifyCloseStatCh: if err == nil { + c.log.Debug("redialer stopped") return } @@ -81,12 +91,16 @@ func (c *Consumer) redialer() { //nolint:gocognit,gocyclo select { case c.redialCh <- err: + c.log.Debug("redialer stopped") return default: + c.log.Debug("redialer stopped") return } case <-c.stopCh: + c.log.Debug("starting stop routine") + pch := <-c.publishChan stCh := <-c.stateChan