Use retry when calling DMaaP and ECS
Issue-ID: NONRTRIC-617
Signed-off-by: elinuxhenrik <henrik.b.andersson@est.tech>
Change-Id: I43b0a3e8d7ebb439a22154b0246af5b05342af27
diff --git a/dmaap-mediator-producer/simulator/consumersimulator.go b/dmaap-mediator-producer/simulator/consumersimulator.go
index 03da6f4..df81385 100644
--- a/dmaap-mediator-producer/simulator/consumersimulator.go
+++ b/dmaap-mediator-producer/simulator/consumersimulator.go
@@ -53,7 +53,12 @@
JobResultUri string `json:"job_result_uri"`
InfoTypeId string `json:"info_type_id"`
JobDefinition string `json:"job_definition"`
- }{fmt.Sprintf("test%v", port), fmt.Sprintf("http://localhost:%v/jobs", port), "STD_Fault_Messages", "{}"}
+ }{
+ JobOwner: fmt.Sprintf("test%v", port),
+ JobResultUri: fmt.Sprintf("http://localhost:%v/jobs", port),
+ InfoTypeId: "STD_Fault_Messages",
+ JobDefinition: "{}",
+ }
fmt.Print("Registering consumer: ", jobInfo)
body, _ := json.Marshal(jobInfo)
putErr := restclient.Put(fmt.Sprintf("http://localhost:8083/data-consumer/v1/info-jobs/job%v", port), body, &httpClient)