X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fxapp%2Fgenerator.go;h=5a17ad4bfde8e75af958642ff799cbb8f9409a76;hb=c8382f13e7126e4038b88b0f8af33db983b7ea3a;hp=9f3527d0a40cb291e64c8297ae7a553641ef5869;hpb=d969b203c9d3b7e3bbf98257ed17edaddd2453b1;p=ric-plt%2Fxapp-frame.git

diff --git a/test/xapp/generator.go b/test/xapp/generator.go
index 9f3527d..5a17ad4 100755
--- a/test/xapp/generator.go
+++ b/test/xapp/generator.go
@@ -17,8 +17,8 @@ var (
 type Generator struct {
 }
 
-func (m Generator) Consume(mtype, subId int, payload []byte, meid *xapp.RMRMeid) (err error) {
-	xapp.Logger.Debug("message received - type=%d subId=%d meid=%v", mtype, subId, meid)
+func (m Generator) Consume(params *xapp.RMRParams) (err error) {
+	xapp.Logger.Debug("message received - type=%d txid=%s ubId=%d meid=%s", params.Mtype, params.Xid, params.SubId, params.Meid.RanName)
 
 	mux.Lock()
 	rx++
@@ -54,7 +54,13 @@ func runTests(mtype, subId, amount, msize, ack int) {
 
 	start := time.Now()
 	for i := 0; i < amount; i++ {
-		if ok := xapp.Rmr.Send(mtype, subId, s, &xapp.RMRMeid{PlmnID: "123456", EnbID: "7788"}); ok {
+		params := &xapp.RMRParams{}
+		params.Mtype = mtype
+		params.SubId = subId
+		params.Payload = s
+		params.Meid = &xapp.RMRMeid{PlmnID: "123456", EnbID: "7788", RanName: "RanName-gnb-1234"}
+		params.Xid = "TestXID1234"
+		if ok := xapp.Rmr.SendMsg(params); ok {
 			tx++
 			if ack != 0 {
 				wg.Add(1)