X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fteststub%2FcontrolRmrStub.go;h=d710dca653847ccb87f06182042dc756b0fa05cf;hb=37f85a0157751a7e34e03f766d356ce890bad838;hp=60b3cc55869a79c08ad77e022444429df8c27f20;hpb=9dc5adc78d459157a42ef8997eeced82a3616f01;p=ric-plt%2Fsubmgr.git

diff --git a/pkg/teststub/controlRmrStub.go b/pkg/teststub/controlRmrStub.go
index 60b3cc5..d710dca 100644
--- a/pkg/teststub/controlRmrStub.go
+++ b/pkg/teststub/controlRmrStub.go
@@ -20,7 +20,6 @@ package teststub
 
 import (
 	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
-	"strconv"
 	"strings"
 	"testing"
 	"time"
@@ -67,13 +66,26 @@ func (tc *RmrStubControl) TestMsgChanEmpty(t *testing.T) {
 	}
 }
 
-func (tc *RmrStubControl) Init(desc string, srcId RmrSrcId, rtgSvc RmrRtgSvc, stat string, initMsg int) {
+func (tc *RmrStubControl) Init(desc string, srcId RmrSrcId, rtgSvc RmrRtgSvc, statDesc string, initMsg int) {
 	tc.InitMsg = initMsg
 	tc.Active = false
 	tc.RecvChan = make(chan *xapp.RMRParams)
 	tc.RmrControl.Init(desc, srcId, rtgSvc)
 
-	tc.RMRClient = xapp.NewRMRClientWithParams("tcp:"+strconv.FormatUint(uint64(srcId.Port), 10), 65534, 0, stat)
+	tc.RMRClient = xapp.NewRMRClientWithParams(&xapp.RMRClientParams{
+		StatDesc: statDesc,
+		RmrData: xapp.PortData{
+			Name:       "", // Not used currently
+			Port:       int(srcId.Port),
+			MaxSize:    65534,
+			ThreadType: 0,
+			LowLatency: false,
+			FastAck:    false,
+			//Policies:				// Not used currently
+			MaxRetryOnFailure: 1,
+		},
+	})
+
 	tc.RMRClient.SetReadyCB(tc.ReadyCB, nil)
 	go tc.RMRClient.Start(tc)