X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Finternal%2Fjobs%2Fjobs.go;h=867894f76f279ea073f4304cfc254e12db6c1297;hb=ba93486b43fb1cda492ba27ae4637a6e0160ae66;hp=b6616a1ba5189a4a625c22e6b7e7c01104ef52bc;hpb=09e21f39a3ffcfc2063110bcad028014b0056398;p=nonrtric.git

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)