- payload_seq_num, err := r.GetSubscriptionResponseSequenceNumber(params.Payload)
- if err != nil {
- xapp.Logger.Error("Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
+ switch params.Mtype {
+ case xapp.RICMessageTypes["RIC_SUB_RESP"]:
+ payloadSeqNum, err := r.GetSubscriptionResponseSequenceNumber(params.Payload)
+ if err != nil {
+ xapp.Logger.Error("SUBRESP: Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
+ }
+ xapp.Logger.Info("Subscription Response Message Received: RMR SUBSCRIPTION_ID: %v | PAYLOAD SEQUENCE_NUMBER: %v", params.SubId, payloadSeqNum)
+ return err
+ case xapp.RICMessageTypes["RIC_SUB_DEL_RESP"]:
+ payloadSeqNum, err := r.GetSubscriptionDeleteResponseSequenceNumber(params.Payload)
+ if err != nil {
+ xapp.Logger.Error("DELRESP: Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
+ }
+ xapp.Logger.Info("Subscription Delete Response Message Received: RMR SUBSCRIPTION_ID: %v | PAYLOAD SEQUENCE_NUMBER: %v", params.SubId, payloadSeqNum)
+ return err
+ default:
+ err = errors.New("Message Type " + strconv.Itoa(params.Mtype) + " is discarded")
+ xapp.Logger.Error("Unknown message type: %v", err)
+ return