X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fxapp%2Fforwarder.go;h=d6032a4736147ad993f158b713040cd49c6d6c2b;hb=5b964f4d8e00797d0556dfb3629753945698150e;hp=03a31549aff9addd8cffee50e732348cd0b803f2;hpb=2e78e42c5896b61b77ab3a97e45704f6749161b2;p=ric-plt%2Fxapp-frame.git

diff --git a/test/xapp/forwarder.go b/test/xapp/forwarder.go
index 03a3154..d6032a4 100755
--- a/test/xapp/forwarder.go
+++ b/test/xapp/forwarder.go
@@ -7,27 +7,28 @@ import (
 type Forwarder struct {
 }
 
-func (m Forwarder) Consume(mtype, subId, len int, payload []byte) (err error) {
-	xapp.Logger.Debug("Message received - type=%d subId=%d len=%d", mtype, subId, len)
+func (m Forwarder) Consume(params *xapp.RMRParams) (err error) {
+	xapp.Logger.Debug("Message received - type=%d txid=%s subId=%d meid=%v", 
+			params.Mtype, params.Xid, params.SubId, params.Meid)
 
 	// Store data and reply with the same message payload
 	if xapp.Config.GetInt("test.store") != 0 {
-		xapp.Sdl.Store("myKey", payload)
+		xapp.Sdl.Store("myKey", params.Payload)
 	}
 
 	mid := xapp.Config.GetInt("test.mtype")
 	if mid != 0 {
-		mtype = mid
+		params.Mtype = mid
 	} else {
-		mtype = mtype + 1
+		params.Mtype = params.Mtype + 1
 	}
 
 	sid := xapp.Config.GetInt("test.subId")
 	if sid != 0 {
-		subId = sid
+		params.SubId = sid
 	}
 
-	if ok := xapp.Rmr.Send(mtype, subId, len, payload); !ok {
+	if ok := xapp.Rmr.SendRts(params); !ok {
 		xapp.Logger.Info("Rmr.Send failed ...")
 	}
 	return