commit f31c7f8bd4985c84f9126d071439c1a4de57f704
author JosephKeenan <joseph.keenan@est.tech> Tue May 24 18:59:25 2022 +0100
committer JosephKeenan <joseph.keenan@est.tech> Wed May 25 10:47:34 2022 +0100
tree 3b5d91b6357705304ae95fe1ad01156afbded020
parent 4cf4962b74765a5afe234aa258a9143ea6936f73

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>

cps-application/src/main/resources/application.yml

diff --git a/cps-application/src/main/resources/application.yml b/cps-application/src/main/resources/application.yml
index 7ad22e9..692996c 100644
--- a/cps-application/src/main/resources/application.yml
+++ b/cps-application/src/main/resources/application.yml
@@ -70,6 +70,19 @@
         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 @@
             queue-capacity: 500

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

             thread-name-prefix: Async-

-

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

 

 springdoc:

     swagger-ui: