X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Frmr.go;h=d310b3a0d0d3016a7ab95b4fc89b049b768b8eed;hb=c30343741fcdad16a4a6cc5396043ecf605f852f;hp=9a3116d78ccc88c8a7768a7b4e5d3713b8bf7895;hpb=1307b2d8d34f48bf44267efc2d1e607823c8d06d;p=ric-plt%2Fxapp-frame.git

diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go
index 9a3116d..d310b3a 100755
--- a/pkg/xapp/rmr.go
+++ b/pkg/xapp/rmr.go
@@ -155,11 +155,14 @@ func (m *RMRClient) Worker(taskName string, msgSize int) {
 		}
 		m.UpdateStatCounter("Received")
 
+		m.msgWg.Add(1)
 		go m.parseMessage(rxBuffer)
+		m.msgWg.Wait()
 	}
 }
 
 func (m *RMRClient) parseMessage(rxBuffer *C.rmr_mbuf_t) {
+	defer m.msgWg.Done()
 	if len(m.consumers) == 0 {
 		Logger.Info("rmrClient: No message handlers defined, message discarded!")
 		return