X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fservices%2Frmr_service.go;h=860f5daaae15422bfab7fe3afb7d84600ec28951;hb=refs%2Fchanges%2F36%2F936%2F1;hp=a0126afe9a313b8a8493b376a724a3f859257305;hpb=966f2102168cad95b8aa1bc83241b4b6730ab1e2;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/services/rmr_service.go b/E2Manager/services/rmr_service.go
index a0126af..860f5da 100644
--- a/E2Manager/services/rmr_service.go
+++ b/E2Manager/services/rmr_service.go
@@ -21,7 +21,6 @@ import (
 	"e2mgr/logger"
 	"e2mgr/models"
 	"e2mgr/rmrCgo"
-	"e2mgr/sessions"
 	"strconv"
 	"sync"
 )
@@ -41,17 +40,15 @@ func NewRmrConfig(port int, maxMsgSize int, flags int, logger *logger.Logger) *R
 type RmrService struct {
 	Config      *RmrConfig
 	Messenger   *rmrCgo.RmrMessenger
-	E2sessions  sessions.E2Sessions
 	RmrResponse chan *models.NotificationResponse
 }
 
 // NewRmrService instantiates a new Rmr service instance
-func NewRmrService(rmrConfig *RmrConfig, msrImpl rmrCgo.RmrMessenger, e2sessions sessions.E2Sessions, rmrResponse chan *models.NotificationResponse) *RmrService {
+func NewRmrService(rmrConfig *RmrConfig, msrImpl rmrCgo.RmrMessenger, rmrResponse chan *models.NotificationResponse) *RmrService {
 
 	return &RmrService{
 		Config:      rmrConfig,
 		Messenger:   msrImpl.Init("tcp:"+strconv.Itoa(rmrConfig.Port), rmrConfig.MaxMsgSize, rmrConfig.Flags, rmrConfig.Logger),
-		E2sessions:  e2sessions,
 		RmrResponse: rmrResponse,
 	}
 }
@@ -84,7 +81,6 @@ func (r *RmrService) SendRmrMessage(response *models.NotificationResponse) error
 	_, err := (*r.Messenger).SendMsg(msg, r.Config.MaxMsgSize)
 
 	if err != nil {
-		r.Config.Logger.Errorf("#rmr_service.SendRmrMessage - error: %#v\n", err)
 		return err
 	}
 	return nil
@@ -101,7 +97,9 @@ func (r *RmrService) SendResponse() {
 		}
 
 		r.Config.Logger.Debugf("#rmr_service.SendResponse - Going to send message: %#v\n", response)
-		r.SendRmrMessage(response)
+		if err := r.SendRmrMessage(response); err != nil {
+			r.Config.Logger.Errorf("#rmr_service.SendResponse - error: %#v\n", err)
+		}
 	}
 }