X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fservices%2Frmrsender%2Frmr_sender.go;h=5df261d4dea14672b3081e5eb0ea126a9d5f2320;hb=b3805a9d29e2c7f6f14e3fedfa1ba504f734eea9;hp=10e6a4276b33a9acac0368ee563f09b92633c9d8;hpb=f1035e286c9cdb58fd786daf4d6c5cc9bea45a37;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/services/rmrsender/rmr_sender.go b/E2Manager/services/rmrsender/rmr_sender.go
index 10e6a42..5df261d 100644
--- a/E2Manager/services/rmrsender/rmr_sender.go
+++ b/E2Manager/services/rmrsender/rmr_sender.go
@@ -38,8 +38,22 @@ func NewRmrSender(logger *logger.Logger, messenger rmrCgo.RmrMessenger) *RmrSend
 	}
 }
 
+func (r *RmrSender) WhSend(rmrMessage *models.RmrMessage) error {
+	msg := rmrCgo.NewMBuf(rmrMessage.MsgType, len(rmrMessage.Payload), rmrMessage.RanName, &rmrMessage.Payload, &rmrMessage.XAction, rmrMessage.GetMsgSrc())
+
+	_, err := r.messenger.WhSendMsg(msg, true)
+
+	if err != nil {
+		r.logger.Errorf("#RmrSender.WhSend - RAN name: %s , Message type: %d - Failed sending message. Error: %v", rmrMessage.RanName, rmrMessage.MsgType, err)
+		return err
+	}
+
+	r.logger.Infof("#RmrSender.WhSend - RAN name: %s , Message type: %d - Successfully sent RMR message", rmrMessage.RanName, rmrMessage.MsgType)
+	return nil
+}
+
 func (r *RmrSender) Send(rmrMessage *models.RmrMessage) error {
-	msg := rmrCgo.NewMBuf(rmrMessage.MsgType, len(rmrMessage.Payload), rmrMessage.RanName, &rmrMessage.Payload, &rmrMessage.XAction)
+	msg := rmrCgo.NewMBuf(rmrMessage.MsgType, len(rmrMessage.Payload), rmrMessage.RanName, &rmrMessage.Payload, &rmrMessage.XAction, rmrMessage.GetMsgSrc())
 
 	_, err := r.messenger.SendMsg(msg, true)
 
@@ -53,7 +67,7 @@ func (r *RmrSender) Send(rmrMessage *models.RmrMessage) error {
 }
 
 func (r *RmrSender) SendWithoutLogs(rmrMessage *models.RmrMessage) error {
-	msg := rmrCgo.NewMBuf(rmrMessage.MsgType, len(rmrMessage.Payload), rmrMessage.RanName, &rmrMessage.Payload, &rmrMessage.XAction)
+	msg := rmrCgo.NewMBuf(rmrMessage.MsgType, len(rmrMessage.Payload), rmrMessage.RanName, &rmrMessage.Payload, &rmrMessage.XAction, rmrMessage.GetMsgSrc())
 
 	_, err := r.messenger.SendMsg(msg, false)