X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pm-rapp%2Fmain.go;h=86f1b3c95ef89c2670c7e85c4a08b30affed0f15;hb=refs%2Fchanges%2F93%2F11793%2F4;hp=c718add586c5ad924c97f74d9b660d1c9d2346a1;hpb=6ab531b7836594aa22442600d829e96ea3b3fcda;p=nonrtric%2Fplt%2Franpm.git diff --git a/pm-rapp/main.go b/pm-rapp/main.go index c718add..86f1b3c 100644 --- a/pm-rapp/main.go +++ b/pm-rapp/main.go @@ -45,10 +45,8 @@ import ( type JobDefinition struct { InfoTypeID string `json:"info_type_id"` JobOwner string `json:"job_owner"` - JobResultURI string `json:"job_result_uri"` + StatusNotificationURI string `json:"status_notification_uri"` JobDefinition struct { - KafkaOutputTopic string `json:"kafkaOutputTopic"` - FilterType string `json:"filterType"` Filter json.RawMessage `json:"filter"` DeliveryInfo struct { Topic string `json:"topic"` @@ -165,13 +163,12 @@ func main() { os.Exit(1) } job_type := job_json.InfoTypeID - job_json.JobDefinition.KafkaOutputTopic = topic job_json.JobDefinition.DeliveryInfo.Topic = topic job_json.JobDefinition.DeliveryInfo.BootStrapServers = bootstrapserver - gid = "pm-rapp-" + job_type + "-" + rapp_id + gid = "pm-rapp-" + job_type + "-" + rapp_id - jobid = "rapp-job-" + job_type + "-" + rapp_id + jobid = "rapp-job-" + job_type + "-" + rapp_id json_bytes, err := json.Marshal(job_json) if err != nil {