Moving RMR message reciver into go routine

[ric-plt/a1.git] / a1-go / pkg / rmr / rmr.go

diff --git a/a1-go/pkg/rmr/rmr.go b/a1-go/pkg/rmr/rmr.go
index b7cac0e..c0366af 100644 (file)
--- a/a1-go/pkg/rmr/rmr.go
+++ b/a1-go/pkg/rmr/rmr.go
@@ -264,6 +264,6 @@ func (rmr *RmrSender) Consume(msg *xapp.RMRParams) (err error) {
 
 func (rmr *RmrSender) RmrRecieveStart() {
        a1.Logger.Debug("Inside RmrRecieveStart function ")
-       rmr.rmrclient.Start(rmr)
+       go rmr.rmrclient.Start(rmr)
        a1.Logger.Debug("Reciever started")
 }