O-DU Slice Assurance App towards latest O-DU implementation

[nonrtric.git] / test / usecases / odusliceassurance / goversion / main.go

diff --git a/test/usecases/odusliceassurance/goversion/main.go b/test/usecases/odusliceassurance/goversion/main.go
index f1c8d42..337e4e0 100644 (file)
--- a/test/usecases/odusliceassurance/goversion/main.go
+++ b/test/usecases/odusliceassurance/goversion/main.go
@@ -29,7 +29,7 @@ import (
        "oransc.org/usecase/oduclosedloop/internal/sliceassurance"
 )
 
-const TOPIC string = "unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT"
+const TOPIC string = "/events/unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT/myG/C1"
 
 var configuration *config.Config
 
@@ -41,14 +41,12 @@ func main() {
 
        log.Debug("Using configuration: ", configuration)
 
-       dmaapUrl := configuration.MRHost + ":" + configuration.MRPort
-
        if err := validateConfiguration(configuration); err != nil {
                log.Fatalf("Unable to start consumer due to configuration error: %v", err)
        }
 
        a := sliceassurance.App{}
-       a.Initialize(dmaapUrl, configuration.SDNRAddress)
+       a.Initialize(configuration)
        go a.Run(TOPIC, configuration.Polltime)
 
        http.HandleFunc("/status", statusHandler)