Code Review / sdc.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 0d2e96c) | patch
[SDC] Add kafka native messaging 67/131367/16
authordavid.mcweeney <david.mcweeney@est.tech>
Tue, 4 Oct 2022 14:46:14 +0000 (15:46 +0100)
committerMichael Morris <michael.morris@est.tech>
Tue, 25 Oct 2022 11:24:02 +0000 (11:24 +0000)
commit47f96dd966663f7f46b719451c0752721a2940a3
tree9d875ce43f96cf3e570cc812d907fa2edd3b7945tree | snapshot
parent0d2e96c125aab4e4edfc0a8b897353c0fabdd885commit | diff
[SDC] Add kafka native messaging

Change-Id: I5ab8f580947cbc264d94bec48a5e8b659dc44c08
Issue-ID: DMAAP-1787
Signed-off-by: david.mcweeney <david.mcweeney@est.tech>
13 files changed:
catalog-be/pom.xml diff | blob | history
catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTask.java diff | blob | history
catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTask.java diff | blob | history
catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionNotificationSender.java diff | blob | history
catalog-be/src/main/java/org/openecomp/sdc/be/components/kafka/KafkaHandler.java [new file with mode: 0644] blob
catalog-be/src/main/java/org/openecomp/sdc/be/components/kafka/SdcKafkaConsumer.java [new file with mode: 0644] blob
catalog-be/src/main/java/org/openecomp/sdc/be/components/kafka/SdcKafkaProducer.java [new file with mode: 0644] blob
catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/CambriaHandlerTest.java diff | blob | history
catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTaskTest.java diff | blob | history
catalog-be/src/test/java/org/openecomp/sdc/be/components/kafka/KafkaHandlerTest.java [new file with mode: 0644] blob
catalog-be/src/test/java/org/openecomp/sdc/be/components/kafka/SdcKafkaConsumerTest.java [new file with mode: 0644] blob
catalog-be/src/test/java/org/openecomp/sdc/be/components/kafka/SdcKafkaProducerTest.java [new file with mode: 0644] blob
pom.xml diff | blob | history
SDC Parent Project Catalog FE and BE