X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fxapp-mgmt%2Fmsgs_proc.cc;h=99eb45329a081fe9f4abedf2c486d590856179e8;hb=refs%2Fchanges%2F42%2F4042%2F2;hp=3d45672c19b730c27518f514a320c95c19c28c6f;hpb=0f5c234d5da8897f2f831e02ff03912e582ba6e9;p=ric-app%2Fhw.git diff --git a/src/xapp-mgmt/msgs_proc.cc b/src/xapp-mgmt/msgs_proc.cc index 3d45672..99eb453 100644 --- a/src/xapp-mgmt/msgs_proc.cc +++ b/src/xapp-mgmt/msgs_proc.cc @@ -105,9 +105,10 @@ bool XappMsgHandler::a1_policy_handler(char * message, int *message_len, a1_pol mdclog_write(MDCLOG_ERR, "Error : %s, %d:: Could not extract policy type id from %s\n", __FILE__, __LINE__, message); return false; } - helper.policy_type_id = ref2->GetString(); + //helper.policy_type_id = ref2->GetString(); + helper.policy_type_id = to_string(ref2->GetInt()); - // Extract policy instance id + // Extract policy instance id rapidjson::Pointer temp("/policy_instance_id"); rapidjson::Value * ref = temp.Get(doc); if (ref == NULL){ @@ -174,7 +175,10 @@ void XappMsgHandler::operator()(rmr_mbuf_t *message, bool *resend){ break; case A1_POLICY_REQ: + + mdclog_write(MDCLOG_INFO, "In Message Handler: Received A1_POLICY_REQ."); helper.handler_id = xapp_id; + res = a1_policy_handler((char*)message->payload, &message->len, helper); if(res){ message->mtype = A1_POLICY_RESP; // if we're here we are running and all is ok