+ return make([]byte, 0), errors.New("Unable to decode data provided in RCO_RAWDATA environment variable")
+ }
+ payload, err = e.SetSubscriptionResponseSequenceNumber(skeleton, sub_id)
+ return
+}
+
+func (e E2t) Consume(mtype, sub_id int, len int, payload []byte) (err error) {
+ payload_seq_num, err := e.GetSubscriptionRequestSequenceNumber(payload)
+ if err != nil {
+ xapp.Logger.Error("Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
+ }
+ xapp.Logger.Info("Message Received: RMR SUBSCRIPTION_ID: %v | PAYLOAD SEQUENCE_NUMBER: %v", sub_id, payload_seq_num)
+ err = e.sendSubscriptionResponse(uint16(sub_id))
+ return
+}
+
+func (e *E2t) sendSubscriptionResponse(sub_id uint16) (err error) {
+ payload, err := e.GeneratePayload(sub_id)
+ if err != nil {
+ xapp.Logger.Debug(err.Error())