Merge "Update Dmaap topic"
authorHenrik Andersson <henrik.b.andersson@est.tech>
Wed, 12 Jan 2022 06:39:55 +0000 (06:39 +0000)
committerGerrit Code Review <gerrit@o-ran-sc.org>
Wed, 12 Jan 2022 06:39:55 +0000 (06:39 +0000)
test/usecases/odusliceassurance/goversion/main.go
test/usecases/odusliceassurance/goversion/stub/sdnr/sdnrstub.go

index 8366843..f1c8d42 100644 (file)
@@ -29,7 +29,7 @@ import (
        "oransc.org/usecase/oduclosedloop/internal/sliceassurance"
 )
 
-const TOPIC string = "/events/unauthenticated.PERFORMANCE_MEASUREMENTS"
+const TOPIC string = "unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT"
 
 var configuration *config.Config
 
index d0b5b8a..41cc928 100644 (file)
@@ -109,8 +109,6 @@ func getDistributedUnitFunctions(w http.ResponseWriter, r *http.Request) {
 }
 
 func updateRRMPolicyDedicatedRatio(w http.ResponseWriter, r *http.Request) {
-       //vars := mux.Vars(r)
-       fmt.Println("::updateRRMPolicyDedicatedRatio::")
        var prMessage messages.DistributedUnitFunction
        decoder := json.NewDecoder(r.Body)
 
@@ -121,7 +119,6 @@ func updateRRMPolicyDedicatedRatio(w http.ResponseWriter, r *http.Request) {
        defer r.Body.Close()
 
        fmt.Println("prMessage: ", prMessage)
-       //prMessage.Id = vars["POLICY-ID"]
 
        respondWithJSON(w, http.StatusOK, map[string]string{"status": "200"})
 }