X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fservices%2Frmrreceiver%2Frmr_receiver.go;h=0a8eb8d4e828b28654d83f9367af8854e7bddc09;hb=a5f90ced0f8e4e9aeb89de647ca78089a91c1995;hp=60f33301f6dca381164163fc5f11197eaa9a85ea;hpb=2c9d450c93e4f0b312a68d39429efb685ec02022;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/services/rmrreceiver/rmr_receiver.go b/E2Manager/services/rmrreceiver/rmr_receiver.go
index 60f3330..0a8eb8d 100644
--- a/E2Manager/services/rmrreceiver/rmr_receiver.go
+++ b/E2Manager/services/rmrreceiver/rmr_receiver.go
@@ -29,10 +29,10 @@ import (
 type RmrReceiver struct {
 	logger    *logger.Logger
 	nManager  *notificationmanager.NotificationManager
-	messenger *rmrCgo.RmrMessenger
+	messenger rmrCgo.RmrMessenger
 }
 
-func NewRmrReceiver(logger *logger.Logger, messenger *rmrCgo.RmrMessenger, nManager *notificationmanager.NotificationManager) *RmrReceiver {
+func NewRmrReceiver(logger *logger.Logger, messenger rmrCgo.RmrMessenger, nManager *notificationmanager.NotificationManager) *RmrReceiver {
 	return &RmrReceiver{
 		logger:    logger,
 		nManager:  nManager,
@@ -43,14 +43,15 @@ func NewRmrReceiver(logger *logger.Logger, messenger *rmrCgo.RmrMessenger, nMana
 func (r *RmrReceiver) ListenAndHandle() {
 
 	for {
-		mbuf, err := (*r.messenger).RecvMsg()
-		r.logger.Debugf("#RmrReceiver.ListenAndHandle - Going to handle received message: %#v\n", mbuf)
+		mbuf, err := r.messenger.RecvMsg()
 
 		if err != nil {
-			// TODO: error handling?
+			r.logger.Errorf("#RmrReceiver.ListenAndHandle - error: %s", err)
 			continue
 		}
 
+		r.logger.Debugf("#RmrReceiver.ListenAndHandle - Going to handle received message: %#v\n", mbuf)
+
 		// TODO: go routine?
 		_ = r.nManager.HandleMessage(mbuf)
 	}