X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=icsversion%2Finternal%2Fodusliceassurance%2FmessageHandler.go;h=c2b988d16171e1c25bc04e970ea6809646d0b521;hb=refs%2Fchanges%2F73%2F10473%2F1;hp=2aee0756119c38251f3afa899946ec896f239f94;hpb=16f26ec9bec7e406398340473de228706f75e97f;p=nonrtric%2Frapp%2Fransliceassurance.git

diff --git a/icsversion/internal/odusliceassurance/messageHandler.go b/icsversion/internal/odusliceassurance/messageHandler.go
index 2aee075..c2b988d 100644
--- a/icsversion/internal/odusliceassurance/messageHandler.go
+++ b/icsversion/internal/odusliceassurance/messageHandler.go
@@ -21,6 +21,7 @@
 package sliceassurance
 
 import (
+	"bytes"
 	"encoding/json"
 	"io"
 	"io/ioutil"
@@ -41,7 +42,7 @@ func NewMessageHandler(data *structures.SliceAssuranceMeas) *MessageHandler {
 }
 
 func (handler MessageHandler) ProcessMessage(body io.ReadCloser) {
-	log.Debug("Process messages from Dmaap mediator")
+	log.Debug("Process messages from DMaaP mediator")
 
 	if messages := getVesMessages(body); messages != nil {
 		stdMessages := getStdMessages(messages)
@@ -66,10 +67,14 @@ func getVesMessages(r io.ReadCloser) *[]string {
 		log.Warn(err)
 		return nil
 	}
-	err = json.Unmarshal(body, &messages)
-	if err != nil {
-		log.Warn(err)
-		return nil
+	if bytes.HasPrefix(body, []byte("{")) {
+		messages = append(messages, string(body))
+	} else {
+		err = json.Unmarshal(body, &messages)
+		if err != nil {
+			log.Warn(err)
+			return nil
+		}
 	}
 	return &messages
 }