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

diff --git a/E2Manager/services/rmrreceiver/rmr_receiver.go b/E2Manager/services/rmrreceiver/rmr_receiver.go
index 8cc807f..0a8eb8d 100644
--- a/E2Manager/services/rmrreceiver/rmr_receiver.go
+++ b/E2Manager/services/rmrreceiver/rmr_receiver.go
@@ -13,7 +13,10 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
-//
+
+//  This source code is part of the near-RT RIC (RAN Intelligent Controller)
+//  platform project (RICP).
+
 
 package rmrreceiver
 
@@ -26,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,
@@ -40,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)
 	}