- final List<Predicate> predicates = cmNotificationSubscriptionNcmpInEvent.getData().getPredicates();
- dmiCmNotificationSubscriptionCacheHandler.add(subscriptionId, predicates);
- if ("subscriptionCreated".equals(cloudEvent.getType()) && cmNotificationSubscriptionNcmpInEvent != null) {
- log.info("Subscription for ClientID {} with name {} ...", cloudEvent.getSource(),
- cmNotificationSubscriptionNcmpInEvent.getData().getSubscriptionId());
+ if ("subscriptionCreateRequest".equals(cloudEvent.getType())) {
+ log.info("Subscription for source {} with subscription id {} ...", cloudEvent.getSource(), subscriptionId);
+ cmNotificationSubscriptionHandlerService.processSubscriptionCreateRequest(
+ cmNotificationSubscriptionNcmpInEvent);