X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=icsversion%2Fmain.go;h=eeff5b44c967278563cccd5c93768c7a885deb66;hb=refs%2Fchanges%2F60%2F11360%2F1;hp=b9e9afc39c555488be4aa5199eb04df3ad26cce1;hpb=16f26ec9bec7e406398340473de228706f75e97f;p=nonrtric%2Frapp%2Fransliceassurance.git diff --git a/icsversion/main.go b/icsversion/main.go index b9e9afc..eeff5b4 100644 --- a/icsversion/main.go +++ b/icsversion/main.go @@ -34,8 +34,6 @@ import ( var configuration *config.Configuration var a sliceassurance.App -const TOPIC string = "/events/unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT/myG/C1" - func main() { configuration = config.New() @@ -51,13 +49,18 @@ func main() { a = sliceassurance.App{} a.Initialize(configuration) - go a.StartServer() + go func() { + a.StartServer() + os.Exit(1) // If the startServer function exits, it is because there has been a failure in the server, so we exit. + }() keepConsumerAlive() } func validateConfiguration(configuration *config.Configuration) error { if configuration.ConsumerHost == "" || configuration.ConsumerPort == 0 { return fmt.Errorf("consumer host and port must be provided") + } else if configuration.NodeId == "" { + return fmt.Errorf("NodeId must be provided") } return nil }