From 31268fde2869520a72fa29d06a46b46a67b263e7 Mon Sep 17 00:00:00 2001 From: TeoV Date: Tue, 20 Nov 2018 05:06:17 -0500 Subject: [PATCH] Add logging in case of incorrect amqp credentials fixes #644 --- engine/poster.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/engine/poster.go b/engine/poster.go index 8f30dc706..c3ca47f34 100644 --- a/engine/poster.go +++ b/engine/poster.go @@ -197,10 +197,12 @@ func (pstr *AMQPPoster) Post(chn *amqp.Channel, contentType string, content []by time.Sleep(time.Duration(fib()) * time.Second) } if err != nil && fallbackFileName != utils.META_NONE { + utils.Logger.Warning(fmt.Sprintf(" creating new post channel, err: %s", err.Error())) err = pstr.writeToFile(fallbackFileName, content) return nil, err } } + for i := 0; i < pstr.attempts; i++ { if err = chn.Publish( "", // exchange