Code Review / nonrtric / plt / dmaapadapter.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: c5cfb8c) | patch
PM Filter 43/8143/2
authorPatrikBuhr <patrik.buhr@est.tech>
Wed, 4 May 2022 12:30:28 +0000 (14:30 +0200)
committerPatrikBuhr <patrik.buhr@est.tech>
Wed, 4 May 2022 13:29:46 +0000 (15:29 +0200)
commitae615c3cf14ae330c0f4c8a0b5ca7757a8e566b3
treed24f03ada014d56561752cffa8c2cda81d17c3ddtree | snapshot
parentc5cfb8c9c6b3db3b4b77a1028cf4d0b609121976commit | diff
PM Filter

Updated so that also info received from dmaap can be buffered into an array.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-743
Change-Id: I550a5b0bca4311e4ac4167219c660d58ab91dcf1
17 files changed:
docs/overview.rst diff | blob | history
src/main/java/org/oran/dmaapadapter/repository/Jobs.java diff | blob | history
src/main/java/org/oran/dmaapadapter/repository/MultiMap.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumers.java [deleted file] blob | history
src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicListener.java [moved from src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumer.java with 73% similarity] diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/JobDataConsumer.java [moved from src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataConsumer.java with 84% similarity] diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/TopicListeners.java [moved from src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java with 52% similarity] diff | blob | history
src/main/resources/typeSchema.json [moved from src/main/resources/typeSchemaKafka.json with 100% similarity] blob | history
src/main/resources/typeSchemaDmaap.json [deleted file] blob | history
src/main/resources/typeSchemaPmData.json [moved from src/main/resources/typeSchemaPmDataKafka.json with 100% similarity] blob | history
src/main/resources/typeSchemaPmDataDmaap.json [deleted file] blob | history
src/test/java/org/oran/dmaapadapter/ApplicationTest.java diff | blob | history
src/test/java/org/oran/dmaapadapter/DmaapSimulatorController.java diff | blob | history
src/test/java/org/oran/dmaapadapter/IntegrationWithIcs.java diff | blob | history
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java diff | blob | history
"nonrtric_plt_dmaapadapter"