Merge "Process data-updated event asynchronously"

diff --cc cps-application/src/main/resources/application.yml
index bafe7f4,acf7803..39309d8
--- 1/cps-application/src/main/resources/application.yml
--- 2/cps-application/src/main/resources/application.yml
+++ b/cps-application/src/main/resources/application.yml
@@@ -71,9 -71,16 +71,16 @@@ spring
  notification:\r
      data-updated:\r
          enabled: false\r
 -        topic: ${CPS_CHANGE_EVENT_TOPIC:cps.cfg-state-events}\r
 +        topic: ${CPS_CHANGE_EVENT_TOPIC:cps.data-updated-events}\r
          filters:\r
-             enabled-dataspaces: ${DATASPACE_FILTER_PATTERNS:""}\r
+             enabled-dataspaces: ${NOTIFICATION_DATASPACE_FILTER_PATTERNS:""}\r
+     async-executor:\r
+         core-pool-size: 2\r
+         max-pool-size: 10\r
+         queue-capacity: 500\r
+         wait-for-tasks-to-complete-on-shutdown: true\r
+         thread-name-prefix: Async-\r
+ \r
  \r
  springdoc:\r
      swagger-ui:\r

diff --cc cps-service/src/main/java/org/onap/cps/api/impl/CpsDataServiceImpl.java
index b45645b,a512f67..8989dc8
--- 1/cps-service/src/main/java/org/onap/cps/api/impl/CpsDataServiceImpl.java
--- 2/cps-service/src/main/java/org/onap/cps/api/impl/CpsDataServiceImpl.java
+++ b/cps-service/src/main/java/org/onap/cps/api/impl/CpsDataServiceImpl.java
@@@ -94,21 -96,9 +96,21 @@@ public class CpsDataServiceImpl impleme
          final var dataNode = buildDataNodeFromJson(dataspaceName, anchorName, parentNodeXpath, jsonData);
          cpsDataPersistenceService
              .updateDataLeaves(dataspaceName, anchorName, dataNode.getXpath(), dataNode.getLeaves());
-         notificationService.processDataUpdatedEvent(dataspaceName, anchorName);
+         processDataUpdatedEventAsync(dataspaceName, anchorName);
      }
  
 +    @Override
 +    public void updateNodeLeavesAndExistingDescendantLeaves(final String dataspaceName, final String anchorName,
 +                                                            final String parentNodeXpath,
 +                                                            final String dataNodeUpdatesAsJson) {
 +        final Collection<DataNode> dataNodeUpdates =
 +            buildDataNodeCollectionFromJson(dataspaceName, anchorName, parentNodeXpath, dataNodeUpdatesAsJson);
 +        for (final DataNode dataNodeUpdate : dataNodeUpdates) {
 +            processDataNodeUpdate(dataspaceName, anchorName, dataNodeUpdate);
 +        }
 +        notificationService.processDataUpdatedEvent(dataspaceName, anchorName);
 +    }
 +
      @Override
      public void replaceNodeTree(final String dataspaceName, final String anchorName, final String parentNodeXpath,
          final String jsonData) {

diff --cc cps-service/src/main/java/org/onap/cps/notification/CpsDataUpdatedEventFactory.java
index 26b89fc,6b7f5a8..e0c8fe7
--- 1/cps-service/src/main/java/org/onap/cps/notification/CpsDataUpdatedEventFactory.java
--- 2/cps-service/src/main/java/org/onap/cps/notification/CpsDataUpdatedEventFactory.java
+++ b/cps-service/src/main/java/org/onap/cps/notification/CpsDataUpdatedEventFactory.java
@@@ -35,17 -38,15 +37,17 @@@ import org.onap.cps.utils.DataMapUtils
  import org.springframework.stereotype.Component;
  
  @Component
- class CpsDataUpdatedEventFactory {
+ public class CpsDataUpdatedEventFactory {
  
 +    private static final URI EVENT_SCHEMA;
      private static final URI EVENT_SOURCE;
      private static final String EVENT_TYPE = "org.onap.cps.data-updated-event";
      private static final DateTimeFormatter dateTimeFormatter =
          DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSSZ");
  
-     static  {
+     static {
          try {
 +            EVENT_SCHEMA = new URI("urn:cps:org.onap.cps:data-updated-event-schema:v1");
              EVENT_SOURCE = new URI("urn:cps:org.onap.cps");
          } catch (final URISyntaxException e) {
              // As it is fixed string, I don't expect to see this error