X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Frpe%2Frpe.go;h=39c2bb12df602e93a1232051b3e061c120dce435;hb=bce67475ab8f92b42841dba561fff27b7d239820;hp=b080bcbaf6bbbf27f25f9c31dc72753adfca3dc0;hpb=415a7b22757d283c3ce7fb523d769ac357bed786;p=ric-plt%2Frtmgr.git

diff --git a/pkg/rpe/rpe.go b/pkg/rpe/rpe.go
index b080bcb..39c2bb1 100644
--- a/pkg/rpe/rpe.go
+++ b/pkg/rpe/rpe.go
@@ -115,7 +115,8 @@ func (r *Rpe) addRoute(messageType string, tx *rtmgr.Endpoint, rx *rtmgr.Endpoin
 		if rx != nil {
 			rxList = []rtmgr.EndpointList{[]rtmgr.Endpoint{*rx}}
 		}
-		messageId := strconv.Itoa(xapp.RICMessageTypes[messageType])
+		//messageId := strconv.Itoa(xapp.RICMessageTypes[messageType])
+		messageId := rtmgr.Mtype[messageType]
 		route := rtmgr.RouteTableEntry{
 			MessageType: messageId,
 			TxList:      txList,
@@ -143,7 +144,8 @@ func (r *Rpe) addRoute_rx_list(messageType string, tx *rtmgr.Endpoint, rx []rtmg
 		}
 	}
 
-	messageId := strconv.Itoa(xapp.RICMessageTypes[messageType])
+	//messageId := strconv.Itoa(xapp.RICMessageTypes[messageType])
+	messageId := rtmgr.Mtype[messageType]
 	route := rtmgr.RouteTableEntry{
 		MessageType: messageId,
 		TxList:      txList,
@@ -250,8 +252,6 @@ func (r *Rpe) generatePlatformRoutes(e2TermEp []rtmgr.Endpoint, subManEp *rtmgr.
 			sendEp = subManEp
 		case "E2MAN":
 			sendEp = e2ManEp
-		//case "UEMAN":
-		//	sendEp = ueManEp
 		case "RSM":
 			sendEp = rsmEp
 		case "A1MEDIATOR":
@@ -300,11 +300,6 @@ func (r *Rpe) generateRouteTable(endPointList rtmgr.Endpoints) *rtmgr.RouteTable
 		xapp.Logger.Error("Platform component not found: %v", "E2 Manager")
 		xapp.Logger.Debug("Endpoints: %v", endPointList)
 	}
-	/*ueManEp := getEndpointByName(&endPointList, "UEMAN")
-	if ueManEp == nil {
-		xapp.Logger.Error("Platform component not found: %v", "UE Manger")
-		xapp.Logger.Debug("Endpoints: %v", endPointList)
-	}*/
 	rsmEp := getEndpointByName(&endPointList, "RSM")
 	if rsmEp == nil {
 		xapp.Logger.Error("Platform component not found: %v", "Resource Status Manager")