+ message := <-c
+ payload_seq_num, err := r.GetSubscriptionRequestSequenceNumber(message.Payload)
+ if err != nil {
+ xapp.Logger.Debug("Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
+ }
+ xapp.Logger.Info("Sending Message: TYPE: %v | RMR SUBSCRIPTION_ID: %v | PAYLOAD SEQUENCE_NUMBER: %v)", message.MessageType, message.SubscriptionId, payload_seq_num)
+ xapp.Rmr.Send(message.MessageType, int(message.SubscriptionId), len(message.Payload), message.Payload)
+ }
+}
+
+func (r *Rco) sendInvalidTestMessages(){
+ for {
+ time.Sleep(7 * time.Second)
+ c <- submgr.RmrDatagram{10000, 0, make([]byte, 1)}
+ time.Sleep(7 * time.Second)
+ c <- submgr.RmrDatagram{12010, 0, make([]byte, 1)}