From 934b296dd26156ada2ec877679150e554bc999f7 Mon Sep 17 00:00:00 2001 From: elinuxhenrik Date: Wed, 8 Dec 2021 10:34:57 +0100 Subject: [PATCH] Fix MR polling bug in DMaaP Mediator Issue-ID: NONRTRIC-671 Signed-off-by: elinuxhenrik Change-Id: I4e85952b7ef4ab57e5e1991bc47fc3d1180a6068 --- dmaap-mediator-producer/internal/jobs/jobs.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dmaap-mediator-producer/internal/jobs/jobs.go b/dmaap-mediator-producer/internal/jobs/jobs.go index b6616a1b..867894f7 100644 --- a/dmaap-mediator-producer/internal/jobs/jobs.go +++ b/dmaap-mediator-producer/internal/jobs/jobs.go @@ -23,6 +23,7 @@ package jobs import ( "fmt" "sync" + "time" log "github.com/sirupsen/logrus" "oransc.org/nonrtric/dmaapmediatorproducer/internal/config" @@ -172,6 +173,7 @@ func (jh *jobsHandler) pollAndDistributeMessages(mRAddress string) { messagesBody, error := restclient.Get(mRAddress+jh.topicUrl, jh.pollClient) if error != nil { log.Warn("Error getting data from MR. Cause: ", error) + time.Sleep(time.Minute) // Must wait before trying to call MR again } log.Debug("Received messages: ", string(messagesBody)) jh.distributeMessages(messagesBody) -- 2.16.6