Code Review / policy / clamp.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: a48f784) | patch
Add Synchronization topic in acm runtime 56/138156/2
authorrameshiyer27 <ramesh.murugan.iyer@est.tech>
Mon, 10 Jun 2024 16:08:04 +0000 (17:08 +0100)
committerrameshiyer27 <ramesh.murugan.iyer@est.tech>
Tue, 11 Jun 2024 08:57:17 +0000 (09:57 +0100)
commitc616ee76ee72202bdf485de86b53a92837620c38
treecf85106d3ac1f749616a90e160e1c90cc3c4f5fatree | snapshot
parenta48f784beca5e7aa189217c52cfa83452cf8fc47commit | diff
Add Synchronization topic in acm runtime

New sync topic for acm-ppnt synchronization
Added publisher for the sync topic
Refactor MessageDispatcherActivator for processing more than one topic
parameter.

Issue-ID: POLICY-5030
Change-Id: Id765b433beaf3f51fad9a9c66403a93d21c33797
Signed-off-by: zrrmmua <ramesh.murugan.iyer@est.tech>
19 files changed:
models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantMessageType.java diff | blob | history
models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantRestart.java diff | blob | history
models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantSync.java [new file with mode: 0644] blob
models/src/test/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantRestartTest.java diff | blob | history
models/src/test/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantSyncTest.java [new file with mode: 0644] blob
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/config/messaging/MessageDispatcherActivator.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/config/messaging/Publisher.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/main/parameters/AcRuntimeParameterGroup.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/main/parameters/Topics.java [new file with mode: 0644] blob
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/AbstractParticipantAckPublisher.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/AbstractParticipantPublisher.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/ParticipantRestartPublisher.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/ParticipantSyncPublisher.java [new file with mode: 0644] blob
runtime-acm/src/main/resources/application.yaml diff | blob | history
runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/config/messaging/MessageDispatcherActivatorTest.java diff | blob | history
runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/comm/SupervisionMessagesTest.java diff | blob | history
runtime-acm/src/test/resources/application-prometheus-noauth.yaml diff | blob | history
runtime-acm/src/test/resources/application-test.yaml diff | blob | history
runtime-acm/src/test/resources/parameters/TestParameters.json diff | blob | history
"policy-clamp"