X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Fxapp%2Frmr.go;h=c835408fa303f19c83d1c5b1fcaa6c8fe47212f6;hb=192518d79ebcffe17bf569bf9037321a6fd26d44;hp=a4955d11ebee81dbd618e503fd836a597e2816f8;hpb=54cfa57c5dfb76bfd570054eb08114f46685fd90;p=ric-plt%2Fxapp-frame.git

diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go
index a4955d1..c835408 100755
--- a/pkg/xapp/rmr.go
+++ b/pkg/xapp/rmr.go
@@ -55,13 +55,14 @@ var RMRCounterOpts = []CounterOpts{
 type RMRStatistics struct{}
 
 type RMRClient struct {
-	context   unsafe.Pointer
-	ready     int
-	wg        sync.WaitGroup
-	mux       sync.Mutex
-	stat      map[string]Counter
-	consumers []MessageConsumer
-	readyCb   ReadyCB
+	context       unsafe.Pointer
+	ready         int
+	wg            sync.WaitGroup
+	mux           sync.Mutex
+	stat          map[string]Counter
+	consumers     []MessageConsumer
+	readyCb       ReadyCB
+	readyCbParams interface{}
 }
 
 type MessageConsumer interface {
@@ -105,7 +106,7 @@ func (m *RMRClient) Start(c MessageConsumer) {
 	}
 
 	if m.readyCb != nil {
-		m.readyCb()
+		m.readyCb(m.readyCbParams)
 	}
 
 	m.Wait()
@@ -216,8 +217,9 @@ func (m *RMRClient) IsReady() bool {
 	return m.ready != 0
 }
 
-func (m *RMRClient) SetReadyCB(cb ReadyCB) {
+func (m *RMRClient) SetReadyCB(cb ReadyCB, params interface{}) {
 	m.readyCb = cb
+	m.readyCbParams = params
 }
 
 func (m *RMRClient) GetRicMessageId(name string) (int, bool) {