- Logger.Error("Subscribe: Params=%+v", params.SubscriptionParams)
- if resp, err := createSubscription(params.SubscriptionParams); err == nil {
- return common.NewSubscribeCreated().WithPayload(resp)
+ 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()
+ }