X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Frtmgr%2Frtmgr.go;h=e5e0dcb8aa88afcb11f0cf447bf5bb5e72279835;hb=ab07a4edbce65cc015e025109f51ea32022b2040;hp=06d0f15ca626d4e62b09ca3566c6e771c087a356;hpb=da0fd3afb09b447a54a4b84b67e0965d7d85b8ff;p=ric-plt%2Frtmgr.git

diff --git a/pkg/rtmgr/rtmgr.go b/pkg/rtmgr/rtmgr.go
index 06d0f15..e5e0dcb 100644
--- a/pkg/rtmgr/rtmgr.go
+++ b/pkg/rtmgr/rtmgr.go
@@ -35,6 +35,7 @@ import (
 	"github.com/ghodss/yaml"
 	"io/ioutil"
 	"os"
+	"strings"
 )
 
 var (
@@ -122,12 +123,15 @@ var (
 	Eps  Endpoints
 	Subs SubscriptionList
 	PrsCfg  *PlatformRoutes
+	Mtype MessageTypeList
+	DynamicRouteList []string
 )
 
 func GetPlatformComponents(configfile string) (*PlatformComponents, error) {
 	xapp.Logger.Debug("Invoked rtmgr.GetPlatformComponents(" + configfile + ")")
 	var rcfg ConfigRtmgr
 	var rtroutes RtmgrRoutes
+	var mtypes MessageTypeIdentifier
 	yamlFile, err := os.Open(configfile)
 	if err != nil {
 		return nil, errors.New("cannot open the file due to: " + err.Error())
@@ -147,6 +151,16 @@ func GetPlatformComponents(configfile string) (*PlatformComponents, error) {
         }
         PrsCfg = &(rtroutes.Prs)
 
+	err = json.Unmarshal(jsonByteValue,&mtypes)
+        if err != nil {
+               return nil, errors.New("cannot parse data due to: " + err.Error())
+        } else {
+		xapp.Logger.Debug("Messgaetypes = %v", mtypes)
+		for _,m := range mtypes.Mit {
+			splitstr := strings.Split(m,"=")
+			Mtype[splitstr[0]] = splitstr[1]
+		}
+	}
 	err = json.Unmarshal(jsonByteValue, &rcfg)
 	if err != nil {
 		return nil, errors.New("cannot parse data due to: " + err.Error())