X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Fsimulator%2Fconsumersimulator.go;h=df8138578d734886f462096cc056eb79e3da57fb;hb=refs%2Fchanges%2F47%2F6947%2F1;hp=03da6f4e8a58379bec4a942e0253fecce09995fd;hpb=0af0d6013c831bfea032c34ce85e1dcf28b10855;p=nonrtric.git

diff --git a/dmaap-mediator-producer/simulator/consumersimulator.go b/dmaap-mediator-producer/simulator/consumersimulator.go
index 03da6f4e..df813857 100644
--- a/dmaap-mediator-producer/simulator/consumersimulator.go
+++ b/dmaap-mediator-producer/simulator/consumersimulator.go
@@ -53,7 +53,12 @@ func registerJob(port int) {
 		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)