Code Review / cps.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 556e54f) | patch
[NCMP] Consume & Forward to client topic 80/132680/11
authorseanbeirne <sean.beirne@est.tech>
Fri, 13 Jan 2023 17:13:25 +0000 (17:13 +0000)
committerSeán Beirne <sean.beirne@est.tech>
Mon, 23 Jan 2023 10:09:41 +0000 (10:09 +0000)
commit7d25644c516869c299ea8d93ea915750e5b07203
treec1ca85b53298326c041ce9914bac1ff7c12a7d8ctree | snapshot
parent556e54f5905440e4c9c4fc7fbf9c027877e51517commit | diff
[NCMP] Consume & Forward to client topic

-Consumes event from dmi-cm-events
-Immediately forwards to static topic (topic selection for events comes
later from subscription information)
-Added Kafka test
-SHOULD BE MERGED BEFORE DMI PART

Issue-ID: CPS-138
Signed-off-by: JosephKeenan <joseph.keenan@est.tech>
Change-Id: I0a426381e2c3f9173b8d3916960c05722ad4f77d
Signed-off-by: seanbeirne <sean.beirne@est.tech>
cps-application/src/main/resources/application.yml diff | blob | history
cps-ncmp-events/src/main/resources/schemas/avc-event-schema-v1.json [new file with mode: 0644] blob
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/NcmpAsyncRequestResponseEventConsumer.java diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java [new file with mode: 0644] blob
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventMapper.java [new file with mode: 0644] blob
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventProducer.java [new file with mode: 0644] blob
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventProducerIntegrationSpec.groovy [new file with mode: 0644] blob
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/kafka/MessagingBaseSpec.groovy diff | blob | history
cps-ncmp-service/src/test/resources/sampleAvcInputEvent.json [new file with mode: 0644] blob
"cps"