X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Frmr%2Frmr.go;h=c112b202e76c3f460a103dc56920fbabb53f5f5e;hb=refs%2Fchanges%2F76%2F11876%2F1;hp=d9ec0f08b33201f6300598e124efbb388ab0ceb0;hpb=8e5f4be592d00c05ec1e3b2ea455bc39cb023d68;p=ric-plt%2Fa1.git

diff --git a/pkg/rmr/rmr.go b/pkg/rmr/rmr.go
index d9ec0f0..c112b20 100644
--- a/pkg/rmr/rmr.go
+++ b/pkg/rmr/rmr.go
@@ -136,8 +136,18 @@ func (rmr *RmrSender) Consume(msg *xapp.RMRParams) (err error) {
 			a1.Logger.Error("Unmarshal error : %+v", err)
 			return err
 		}
-		a1.Logger.Debug("message recieved for %d and %d with status : %s", result["policy_type_id"], result["policy_instance_id"], result["status"])
-		rmr.policyManager.SetPolicyInstanceStatus(int(result["policy_type_id"].(float64)), int(result["policy_instance_id"].(float64)), result["status"].(string))
+		policyTypeId := int(result["policy_type_id"].(float64))
+		policyInstanceId := result["policy_instance_id"].(string)
+		policyHandlerId := result["handler_id"].(string)
+		policyStatus := result["status"].(string)
+
+		a1.Logger.Debug("message recieved for %d and %s with status : %s", policyTypeId, policyInstanceId, policyStatus)
+		rmr.policyManager.SetPolicyInstanceStatus(policyTypeId, policyInstanceId, policyStatus)
+		err = rmr.policyManager.SendPolicyStatusNotification(policyTypeId, policyInstanceId, policyHandlerId, policyStatus)
+		if err != nil {
+			a1.Logger.Debug("failed to send policy status notification %v+", err)
+		}
+
 	case "A1_POLICY_QUERY":
 		a1.Logger.Debug("Recived policy query")
 		a1.Logger.Debug("message recieved ", msg.Payload)