Code Review / cps.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 3008608) | patch
Updating the Kafka listener compliance to could events and legacy 04/135204/6
authorraviteja.karumuri <raviteja.karumuri@est.tech>
Thu, 29 Jun 2023 12:57:40 +0000 (13:57 +0100)
committerraviteja.karumuri <raviteja.karumuri@est.tech>
Thu, 29 Jun 2023 14:06:34 +0000 (15:06 +0100)
commitffe0e1ee121e2ca89f82824f193ed0a0e599a2c0
tree71022e9e0f1e564996cd535d5c13bcc5915d8f58tree | snapshot
parent300860865a8dd616083543f7c88cf2c8233c2701commit | diff
Updating the Kafka listener compliance to could events and legacy

# Added filter property to the legay(DMIAsync) Consumer
# Added containerFactory property to the CloudEvent(DataOperation) consumer to use 'cloudEventDeserializtion'

Issue-ID: CPS-1746
Signed-off-by: raviteja.karumuri <raviteja.karumuri@est.tech>
Change-Id: I73315b816eb6446b7e163fd8779bc35fd6cbef63
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/AsyncRestRequestResponseEventConsumer.java [moved from cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/NcmpAsyncRequestResponseEventConsumer.java with 89% similarity] diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumer.java [moved from cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/NcmpAsyncDataOperationEventConsumer.java with 88% similarity] diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/DataOperationRecordFilterStrategy.java [deleted file] blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/async/RecordFilterStrategies.java [new file with mode: 0644] blob
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/CpsAsyncRequestResponseEventIntegrationSpec.groovy diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/DataOperationEventConsumerSpec.groovy [moved from cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncDataOperationEventConsumerSpec.groovy with 94% similarity] diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/FilterStrategiesIntegrationSpec.groovy [moved from cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncDataOperationEventConsumerIntegrationSpec.groovy with 63% similarity] diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/events/lcm/LcmEventsPublisherSpec.groovy diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/kafka/MessagingBaseSpec.groovy diff | blob | history
cps-ncmp-service/src/test/resources/application.yml diff | blob | history
"cps"