4 "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
7 type Forwarder struct {
10 func (m Forwarder) Consume(params *xapp.RMRParams) (err error) {
11 xapp.Logger.Debug("Message received - type=%d txid=%s subId=%d meid=%s",
12 params.Mtype, params.Xid, params.SubId, params.Meid.RanName)
14 // Store data and reply with the same message payload
15 if xapp.Config.GetInt("test.store") != 0 {
16 xapp.Sdl.Store("myKey", params.Payload)
19 mid := xapp.Config.GetInt("test.mtype")
23 params.Mtype = params.Mtype + 1
26 sid := xapp.Config.GetInt("test.subId")
31 if ok := xapp.Rmr.SendRts(params); !ok {
32 xapp.Logger.Info("Rmr.Send failed ...")