X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Fxapp%2Fsubscription.go;h=6a6983ce4bd208a1cb6e0caf0d24ceb5a8c61643;hb=c79bd0e1a4fe855b06c8f8131f162d0ee4a5f9f5;hp=73cb4a29886b57782f9c79ec31197361cadc3df6;hpb=3602bf801fef17e317cb35a4c710118ec80908b9;p=ric-plt%2Fxapp-frame.git

diff --git a/pkg/xapp/subscription.go b/pkg/xapp/subscription.go
index 73cb4a2..6a6983c 100755
--- a/pkg/xapp/subscription.go
+++ b/pkg/xapp/subscription.go
@@ -119,6 +119,7 @@ func (r *Subscriber) Listen(createSubscription SubscriptionHandler, getSubscript
 	// Subscription: Subscribe
 	api.CommonSubscribeHandler = common.SubscribeHandlerFunc(
 		func(params common.SubscribeParams) middleware.Responder {
+			Logger.Error("Subscribe: Params=%+v", params.SubscriptionParams)
 			if resp, err := createSubscription(params.SubscriptionParams); err == nil {
 				return common.NewSubscribeCreated().WithPayload(resp)
 			}
@@ -128,6 +129,7 @@ func (r *Subscriber) Listen(createSubscription SubscriptionHandler, getSubscript
 	// Subscription: Unsubscribe
 	api.CommonUnsubscribeHandler = common.UnsubscribeHandlerFunc(
 		func(p common.UnsubscribeParams) middleware.Responder {
+			Logger.Error("Unsubscribe: SubscriptionID=%+v", p.SubscriptionID)
 			if err := delSubscription(p.SubscriptionID); err == nil {
 				return common.NewUnsubscribeNoContent()
 			}
@@ -154,7 +156,7 @@ func (r *Subscriber) Notify(resp *models.SubscriptionResponse, ep models.Subscri
 		return err
 	}
 
-	clientUrl := fmt.Sprintf("http://%s:%d%s", ep.ServiceName, ep.Port, r.clientUrl)
+	clientUrl := fmt.Sprintf("http://%s:%d%s", ep.Host, *ep.HTTPPort, r.clientUrl)
 
 	retries := viper.GetInt("subscription.retryCount")
 	if retries == 0 {