X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=cmd%2Fappmgr%2Fsubscriptions.go;fp=cmd%2Fappmgr%2Fsubscriptions.go;h=40735a9d1ed1e8760584b8c16c205ffed52cd66d;hb=4021ae6af0b166342a17c2f140fc0b7cc338dea7;hp=1db4c5af3047a6e896805195db2729fe6599e9ab;hpb=b6e413571bf3f44d4cd076815334449831d84e28;p=ric-plt%2Fappmgr.git

diff --git a/cmd/appmgr/subscriptions.go b/cmd/appmgr/subscriptions.go
index 1db4c5a..40735a9 100755
--- a/cmd/appmgr/subscriptions.go
+++ b/cmd/appmgr/subscriptions.go
@@ -107,9 +107,13 @@ func (sd *SubscriptionDispatcher) notifyClients(xapps []Xapp, et EventType) {
 }
 
 func (sd *SubscriptionDispatcher) notify(xapps []Xapp, et EventType, s Subscription, seq int) error {
-	notif := []SubscriptionNotif{}
-	notif = append(notif, SubscriptionNotif{Id: s.req.Id, Version: seq, EventType: string(et), XappData: xapps})
+	xappData, err := json.Marshal(xapps)
+        if err != nil {
+                Logger.Info("json.Marshal failed: %v", err)
+                return err
+        }
 
+	notif := SubscriptionNotif{Id: s.req.Id, Version: seq, EventType: string(et), XApps: string(xappData)}
 	jsonData, err := json.Marshal(notif)
 	if err != nil {
 		Logger.Info("json.Marshal failed: %v", err)
@@ -118,6 +122,7 @@ func (sd *SubscriptionDispatcher) notify(xapps []Xapp, et EventType, s Subscript
 
 	// Execute the request with retry policy
 	return sd.retry(s, func() error {
+		Logger.Info("Posting notification to targetUrl=%s: %v", s.req.TargetUrl, notif)
 		resp, err := http.Post(s.req.TargetUrl, "application/json", bytes.NewBuffer(jsonData))
 		if err != nil {
 			Logger.Info("Posting to subscription failed: %v", err)