4 "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
7 type Forwarder struct {
10 func (m Forwarder) Consume(mtype, subId int, payload []byte, meid *xapp.RMRMeid) (err error) {
11 xapp.Logger.Debug("Message received - type=%d subId=%d meid=%v", mtype, subId, meid)
13 // Store data and reply with the same message payload
14 if xapp.Config.GetInt("test.store") != 0 {
15 xapp.Sdl.Store("myKey", payload)
18 mid := xapp.Config.GetInt("test.mtype")
25 sid := xapp.Config.GetInt("test.subId")
30 if ok := xapp.Rmr.Send(mtype, subId, payload, nil); !ok {
31 xapp.Logger.Info("Rmr.Send failed ...")