Bugfix 90/9290/1
authorPatrikBuhr <patrik.buhr@est.tech>
Sat, 15 Oct 2022 07:44:40 +0000 (09:44 +0200)
committerPatrikBuhr <patrik.buhr@est.tech>
Mon, 17 Oct 2022 05:59:40 +0000 (07:59 +0200)
commitd7d3ed3329904ac2c90a703cc5b5dba191bc4074
tree2d4e62c2ab75ab6f624cc69b60495462813f0a38
parent0504062f8886fb393e618a1eea579d57b47ccc57
Bugfix

The received PM report was read from disc once per subscriber instead of
once.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-773
Change-Id: I434e1e320df5a28dd4dbe518923c6cee7f1e744a
src/main/java/org/oran/dmaapadapter/datastore/DataStore.java
src/main/java/org/oran/dmaapadapter/datastore/FileStore.java
src/main/java/org/oran/dmaapadapter/datastore/S3ObjectStore.java
src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/JobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java
src/test/java/org/oran/dmaapadapter/ApplicationTest.java
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java