Refactor EventsProducer class to remove Generic type for legacyevent 18/142118/1
authormpriyank <priyank.maheshwari@est.tech>
Wed, 24 Sep 2025 12:22:21 +0000 (13:22 +0100)
committermpriyank <priyank.maheshwari@est.tech>
Thu, 25 Sep 2025 10:26:59 +0000 (11:26 +0100)
commitfb8719e95b86724e995212492b725b7d9bb90cce
treec66b893924b90f4784786329ca898f9797d610cd
parentfd797e3d00ad21f68f32bdf32c386bfd0febae14
Refactor EventsProducer class to remove Generic type for legacyevent

- EventsProducer refactored to not use generic type and instead use
  LegacyEvent type for all the events that still uses non-cloud events.
- Events are implementing LegacyEvent interface now just to
  differentiate b/w cloud and non-cloud events when creating a
  kafkatemplate to send events

Issue-ID: CPS-2990
Change-Id: Ic905ceadefca9e492cb999b633c86d13227c30c2
Signed-off-by: mpriyank <priyank.maheshwari@est.tech>
25 files changed:
cps-events/src/main/java/org/onap/cps/events/LegacyEvent.java [new file with mode: 0644]
cps-ncmp-events/pom.xml
cps-ncmp-events/src/main/resources/schemas/lcm/lcm-event-schema-v1.json
cps-ncmp-events/src/main/resources/schemas/ncmp/async-m2m/data-operation-event-schema-1.0.0.json
cps-ncmp-events/src/main/resources/schemas/ncmp/async-m2m/ncmp-async-request-response-event-schema-v1.json
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/config/KafkaConfig.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/data/async/DataOperationEventConsumer.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/data/async/DmiAsyncRequestResponseEventConsumer.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/data/utils/DmiDataOperationsHelper.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/subscription/cmavc/CmAvcEventConsumer.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/subscription/dmi/EventProducer.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/inventory/sync/lcm/LcmEventsProducer.java
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/utils/events/InventoryEventProducer.java
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/config/KafkaConfigSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/async/CpsAsyncRequestResponseEventIntegrationSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/async/DataOperationEventConsumerSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/async/FilterStrategiesIntegrationSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/async/SerializationIntegrationSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/utils/DmiDataOperationsHelperSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/datajobs/subscription/cmavc/CmAvcEventConsumerSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/inventory/sync/lcm/EventsProducerSpec.groovy
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/inventory/sync/lcm/LcmEventsProducerSpec.groovy
cps-service/src/main/java/org/onap/cps/events/CpsDataUpdateEventsProducer.java
cps-service/src/main/java/org/onap/cps/events/EventsProducer.java
cps-service/src/test/groovy/org/onap/cps/events/EventsProducerSpec.groovy