+func (r Rco) Consume(params *xapp.RMRParams) (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
+ }
+}
+
+func (r *Rco) SendRequests() (err error) {
+ message, err := r.GeneratePayload(seedSN)
+ if err != nil {
+ xapp.Logger.Debug(err.Error())
+ return
+ }
+ deletemessage, err := r.GenerateDeletePayload(deleteSeedSN)