X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1-go%2Fpkg%2Frmr%2Fmessages.go;h=36771ef387034b179a6ded444a2bd591ce7de01f;hb=a5d992815f470a349dea86d616509222eb051f97;hp=af4e6c27a4dbe66a598b67fadb9cb970a4bd6593;hpb=327e01cb25524a380f1f1a75e7cbcc9fd81f4972;p=ric-plt%2Fa1.git

diff --git a/a1-go/pkg/rmr/messages.go b/a1-go/pkg/rmr/messages.go
index af4e6c2..36771ef 100644
--- a/a1-go/pkg/rmr/messages.go
+++ b/a1-go/pkg/rmr/messages.go
@@ -43,3 +43,17 @@ func (m *Message) PolicyMessage(policyTypeId string, policyInstanceID string, ht
 	}
 	return string(data), nil
 }
+
+func (m *Message) A1EIMessage(eiJobId string, httpBody string) (string, error) {
+	var datajson interface{}
+	datajson = map[string]string{
+		"ei_job_id": eiJobId,
+		"payload":   httpBody}
+	data, err := json.Marshal(datajson)
+
+	if err != nil {
+		a1.Logger.Error("marshal error : %v", err)
+		return "", err
+	}
+	return string(data), nil
+}