Async request response NCMP -> Client

-Added consumer for DMI events and producer for forwarding to client
-Added schemas for events
-Updated tests
-Added new module for ncmp events
-Used mapstruct for event mapping

Issue-ID: CPS-830
Change-Id: I096d08af9d69092cf8651e11eaa00ce441fc3605
Signed-off-by: sourabh_sourabh <sourabh.sourabh@est.tech>
Signed-off-by: JosephKeenan <joseph.keenan@est.tech>
Signed-off-by: ToineSiebelink <toine.siebelink@est.tech>
Signed-off-by: JosephKeenan <joseph.keenan@est.tech>

1 files changed, 14 insertions, 1 deletions

diff --git a/cps-application/src/main/resources/application.yml b/cps-application/src/main/resources/application.yml
index 7ad22e977e..692996c985 100644
--- a/cps-application/src/main/resources/application.yml
+++ b/cps-application/src/main/resources/application.yml
@@ -70,6 +70,19 @@ spring:
         producer:

             value-serializer: org.springframework.kafka.support.serializer.JsonSerializer

             client-id: cps-core

+        consumer:

+            group-id: ${NCMP_CONSUMER_GROUP_ID:ncmp-group}

+            key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer

+            value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer

+            properties:

+                spring.deserializer.key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer

+                spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer

+                spring.json.value.default.type: org.onap.cps.ncmp.event.model.DmiAsyncRequestResponseEvent

+                spring.json.use.type.headers: false

+app:

+    ncmp:

+        async-m2m:

+            topic: ${NCMP_ASYNC_M2M_TOPIC:ncmp-async-m2m}

 

 notification:

     data-updated:

@@ -85,7 +98,7 @@ notification:
             queue-capacity: 500

             wait-for-tasks-to-complete-on-shutdown: true

             thread-name-prefix: Async-

-

+            time-out-value-in-ms: 2000

 

 springdoc:

     swagger-ui: