if ("subscriptionCreateResponse".equals(eventType)) {
final CmSubscriptionStatus cmSubscriptionStatus = getCmSubscriptionStatus(dmiOutEvent);
- if (ACCEPTED.equals(cmSubscriptionStatus)) {
- cmSubscriptionHandler.updateCmSubscriptionStatus(
- subscriptionId, dmiPluginName, cmSubscriptionStatus);
- }
+ cmSubscriptionHandler.updateCmSubscriptionStatus(subscriptionId, dmiPluginName, cmSubscriptionStatus);
}
}
+ log.info("Finished processing DMI subscription response event with details: | correlationId={} | eventType={}",
+ correlationId, eventType);
}
private CmSubscriptionStatus getCmSubscriptionStatus(final DataJobSubscriptionDmiOutEvent dmiOutEvent) {