-func (r Rco) Consume(mtype, sub_id int, len int, payload []byte) (err error) {
- payload_seq_num, err := r.GetSubscriptionResponseSequenceNumber(payload)
+func (r *Rco) GenerateDeletePayload(sub_id uint16) (payload []byte, err error) {
+ skeleton, err := hex.DecodeString(DELETERAWDATA)
+ if err != nil {
+ return make([]byte, 0), errors.New("Unable to decode data provided in RCO_DELETE RAWDATA environment variable")
+ }
+ xapp.Logger.Info("SetSubscriptionDeleteRequestSequenceNumber1")
+ payload, err = r.SetSubscriptionDeleteRequestSequenceNumber(skeleton, sub_id)
+ xapp.Logger.Info("SetSubscriptionDeleteRequestSequenceNumber2")
+ return
+}
+
+func (r Rco) Consume(params *xapp.RMRParams) (err error) {
+ payload_seq_num, err := r.GetSubscriptionResponseSequenceNumber(params.Payload)