X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fxapp%2Fforwarder.go;h=4e38c3bae773c09fc4bee41011afd28c893840bf;hb=HEAD;hp=63ec16f20df280a39a056c1ace640a85a5367331;hpb=f11ab7a3d67cea79004d4598607fd4fa4c1ee28a;p=ric-plt%2Fxapp-frame.git diff --git a/test/xapp/forwarder.go b/test/xapp/forwarder.go index 63ec16f..4e38c3b 100755 --- a/test/xapp/forwarder.go +++ b/test/xapp/forwarder.go @@ -8,7 +8,8 @@ type Forwarder struct { } func (m Forwarder) Consume(params *xapp.RMRParams) (err error) { - xapp.Logger.Debug("Message received - type=%d subId=%d meid=%v xid=%v", params.Mtype, params.SubId, params.Meid, params.Xid) + xapp.Logger.Debug("Message received - type=%d txid=%s subId=%d meid=%s", + params.Mtype, params.Xid, params.SubId, params.Meid.RanName) // Store data and reply with the same message payload if xapp.Config.GetInt("test.store") != 0 { @@ -27,7 +28,7 @@ func (m Forwarder) Consume(params *xapp.RMRParams) (err error) { params.SubId = sid } - if ok := xapp.Rmr.SendMsg(params); !ok { + if ok := xapp.Rmr.SendRts(params); !ok { xapp.Logger.Info("Rmr.Send failed ...") } return