X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fusecases%2Fodusliceassurance%2Fgoversion%2Fmain.go;h=337e4e02b5ee050c93c6b346bd78f71bfc278ee0;hb=5e92b2132b2300080d8a928b7d9c44906724fd78;hp=05b5edf3372d090072069a114a5a9269fd8d76dd;hpb=9850e546f54b85fec121518828517f1643ef81f8;p=nonrtric.git

diff --git a/test/usecases/odusliceassurance/goversion/main.go b/test/usecases/odusliceassurance/goversion/main.go
index 05b5edf3..337e4e02 100644
--- a/test/usecases/odusliceassurance/goversion/main.go
+++ b/test/usecases/odusliceassurance/goversion/main.go
@@ -22,13 +22,14 @@ package main
 
 import (
 	"fmt"
+	"net/http"
 
 	log "github.com/sirupsen/logrus"
 	"oransc.org/usecase/oduclosedloop/internal/config"
 	"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
 
@@ -36,18 +37,21 @@ func main() {
 	configuration = config.New()
 
 	log.SetLevel(configuration.LogLevel)
-	log.Debug("Using configuration: ", configuration)
+	log.SetFormatter(&log.JSONFormatter{})
 
-	dmaapUrl := configuration.MRHost + ":" + configuration.MRPort
+	log.Debug("Using configuration: ", configuration)
 
 	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.Run(TOPIC, configuration.Polltime)
+	a.Initialize(configuration)
+	go a.Run(TOPIC, configuration.Polltime)
+
+	http.HandleFunc("/status", statusHandler)
 
+	log.Fatal(http.ListenAndServe(":40936", nil))
 }
 
 func validateConfiguration(configuration *config.Config) error {
@@ -56,3 +60,7 @@ func validateConfiguration(configuration *config.Config) error {
 	}
 	return nil
 }
+
+func statusHandler(w http.ResponseWriter, r *http.Request) {
+	// Just respond OK to show the service is alive for now. Might be extended later.
+}