Code Review / nonrtric.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 5e1623a) | patch
NONRTRIC - Implement DMaaP mediator producer service in Java 61/7061/2
authorPatrikBuhr <patrik.buhr@est.tech>
Mon, 15 Nov 2021 11:26:01 +0000 (12:26 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Mon, 15 Nov 2021 16:47:49 +0000 (17:47 +0100)
commitb3896f4ad7912be9e12c05e7d4770fa39752d797
tree0e322228a24d9440ec441a8eeae31656c22e96cctree | snapshot
parent5e1623ab25b62c6c28849bfd862eba4648465922commit | diff
NONRTRIC - Implement DMaaP mediator producer service in Java

Added a possibility fora consumer to choose how many concurrent REST sessions it can handle.
If correct message sequence it to be maintained, this must be set to 1.

Taking a rest if the consumer is unavialable.

Trying to restart strems at overflow, which does not work.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-597
Change-Id: I05ffe17dd39fb7a20aeb394b258c2b0cb0f4c638
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/BeanFactory.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Job.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Jobs.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumer.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumers.java [new file with mode: 0644] blob
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataConsumer.java [new file with mode: 0644] blob
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java [moved from dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumer.java with 60% similarity] diff | blob | history
dmaap-adaptor-java/src/main/resources/typeSchemaKafka.json diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ConsumerController.java diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java diff | blob | history
Parent repository for the O-RAN SC Non Real-Time RIC (NONRTRIC) project.