Refactor UEBNotification class 74/139174/6
authorFiete Ostkamp <Fiete.Ostkamp@telekom.de>
Tue, 8 Oct 2024 09:52:14 +0000 (11:52 +0200)
committerFiete Ostkamp <Fiete.Ostkamp@telekom.de>
Wed, 9 Oct 2024 09:12:06 +0000 (11:12 +0200)
commit180f2967c7db5cbbace67616146a66d9d9658af7
tree106a9019968b489ca717ddeb7a3e93f5328ac509
parent6cc66cadc9db495883ce1211c1a0f712e77f8bc7
Refactor UEBNotification class

- refactor UEBNotification class that it does not use ActiveMQ anymore
  and directly publishes to Kafka
- use .domain.NotificationEvent class
- serialize as late as possible

Issue-ID: AAI-3931
Signed-off-by: Fiete Ostkamp <Fiete.Ostkamp@telekom.de>
Change-Id: I3836519752f810f905a9aed96678d497783a2e5d
26 files changed:
aai-core/src/main/java/org/onap/aai/config/RestBeanConfig.java
aai-core/src/main/java/org/onap/aai/domain/notificationEvent/NotificationEvent.java
aai-core/src/main/java/org/onap/aai/kafka/MessageProducer.java
aai-core/src/main/java/org/onap/aai/kafka/NotificationProducer.java [new file with mode: 0644]
aai-core/src/main/java/org/onap/aai/kafka/NotificationProducerService.java [new file with mode: 0644]
aai-core/src/main/java/org/onap/aai/prevalidation/ValidationService.java
aai-core/src/main/java/org/onap/aai/rest/db/HttpEntry.java
aai-core/src/main/java/org/onap/aai/rest/notification/NotificationService.java
aai-core/src/main/java/org/onap/aai/rest/notification/UEBNotification.java
aai-core/src/main/java/org/onap/aai/web/KafkaConfig.java
aai-core/src/main/java/org/onap/aai/web/KafkaNotificationEventConfig.java [new file with mode: 0644]
aai-core/src/test/java/org/onap/aai/AAISetup.java
aai-core/src/test/java/org/onap/aai/DataLinkSetup.java
aai-core/src/test/java/org/onap/aai/HttpTestUtil.java
aai-core/src/test/java/org/onap/aai/introspection/IntrospectorSerializationTest.java
aai-core/src/test/java/org/onap/aai/kafka/AAIKafkaEventIntegrationTest.java
aai-core/src/test/java/org/onap/aai/prevalidation/ValidationServiceTest.java
aai-core/src/test/java/org/onap/aai/query/builder/QueryBuilderTestAbstraction.java
aai-core/src/test/java/org/onap/aai/rest/ImpliedDeleteIntegrationTest.java
aai-core/src/test/java/org/onap/aai/rest/NotificationDmaapEventTest.java
aai-core/src/test/java/org/onap/aai/rest/db/HttpEntryNotificationIntegrationTest.java
aai-core/src/test/java/org/onap/aai/rest/notification/NotificationServiceTest.java
aai-core/src/test/java/org/onap/aai/rest/notification/UEBNotificationTest.java
aai-core/src/test/java/org/onap/aai/serialization/db/DbSerializer_needsFakeRulesTest.java
aai-core/src/test/resources/payloads/resource/aai-event.json
aai-els-onap-logging/src/main/java/org/onap/aai/util/FormatDate.java