test/xapp/forwarder.go

   1 package main
   2
   3 import (
   4         "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
   5 )
   6
   7 type Forwarder struct {
   8 }
   9
  10 func (m Forwarder) Consume(params *xapp.RMRParams) (err error) {
  11         xapp.Logger.Debug("Message received - type=%d subId=%d meid=%v xid=%v", params.Mtype, params.SubId, params.Meid, params.Xid)
  12
  13         // Store data and reply with the same message payload
  14         if xapp.Config.GetInt("test.store") != 0 {
  15                 xapp.Sdl.Store("myKey", params.Payload)
  16         }
  17
  18         mid := xapp.Config.GetInt("test.mtype")
  19         if mid != 0 {
  20                 params.Mtype = mid
  21         } else {
  22                 params.Mtype = params.Mtype + 1
  23         }
  24
  25         sid := xapp.Config.GetInt("test.subId")
  26         if sid != 0 {
  27                 params.SubId = sid
  28         }
  29
  30         if ok := xapp.Rmr.SendMsg(params); !ok {
  31                 xapp.Logger.Info("Rmr.Send failed ...")
  32         }
  33         return
  34 }
  35
  36 func forwarder() {
  37         xapp.Run(Forwarder{})
  38 }