X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fsubscription.go;h=8f49e996867a179635c21efe98bc9e7f631852d8;hb=9c523a68520e552d051ca922815aa936c8611894;hp=01e351f1a89fdb8f67a8ccabff201fb24b6629d9;hpb=41e3b5845256a1ef3ae70fac702ee545ce5c2905;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/subscription.go b/pkg/xapp/subscription.go index 01e351f..8f49e99 100755 --- a/pkg/xapp/subscription.go +++ b/pkg/xapp/subscription.go @@ -120,11 +120,14 @@ 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) resp, retCode := createSubscription(params.SubscriptionParams) if retCode != common.SubscribeCreatedCode { if retCode == common.SubscribeBadRequestCode { return common.NewSubscribeBadRequest() + } else if retCode == common.SubscribeNotFoundCode { + return common.NewSubscribeNotFound() + } else if retCode == common.SubscribeServiceUnavailableCode { + return common.NewSubscribeServiceUnavailable() } else { return common.NewSubscribeInternalServerError() } @@ -135,7 +138,6 @@ 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) retCode := delSubscription(p.SubscriptionID) if retCode != common.UnsubscribeNoContentCode { if retCode == common.UnsubscribeBadRequestCode { @@ -209,7 +211,6 @@ func (r *Subscriber) Subscribe(p *apimodel.SubscriptionParams) (*apimodel.Subscr if err != nil { return &apimodel.SubscriptionResponse{}, err } - return result.Payload, err }