"oransc.org/usecase/oduclosedloop/internal/sliceassurance"
)
-const TOPIC string = "/events/unauthenticated.PERFORMANCE_MEASUREMENTS"
+const TOPIC string = "/events/unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT/myG/C1"
var configuration *config.Config
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)