diff options
author | 2024-10-08 09:18:39 +0100 | |
---|---|---|
committer | 2024-10-08 13:37:02 +0000 | |
commit | 20ad241b626db4d44bffd08ca0e5d6f2d8f4be4d (patch) | |
tree | 55957befcc2b1703ea2cc4797cd09e209580a966 /runtime-acm/src/main | |
parent | 9632ec36d91bcaf4815444126ac132390eb49433 (diff) |
Add sync message when OutProperties instance change
Add sync message when OutProperties instance change.
Remove update out Properties instance when ac state change happen.
Issue-ID: POLICY-5135
Change-Id: If62521ae3200c8836db92f4825110f14696767df
Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'runtime-acm/src/main')
2 files changed, 13 insertions, 4 deletions
diff --git a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionAcHandler.java b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionAcHandler.java index 6a56a2c2b..4f564478f 100644 --- a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionAcHandler.java +++ b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionAcHandler.java @@ -340,9 +340,6 @@ public class SupervisionAcHandler { var element = automationComposition.getElements().get(acElementAck.getKey()); if (element != null) { element.setMessage(AcmUtils.validatedMessage(acElementAck.getValue().getMessage())); - element.setOutProperties(acElementAck.getValue().getOutProperties()); - element.setOperationalState(acElementAck.getValue().getOperationalState()); - element.setUseState(acElementAck.getValue().getUseState()); if (stage == null) { element.setSubState(SubState.NONE); } diff --git a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java index ea3ef0ff7..3eb471609 100644 --- a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java +++ b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java @@ -34,6 +34,7 @@ import org.onap.policy.clamp.acm.runtime.supervision.comm.ParticipantSyncPublish import org.onap.policy.clamp.models.acm.concepts.AcTypeState; import org.onap.policy.clamp.models.acm.concepts.AutomationComposition; import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionDefinition; +import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionInfo; import org.onap.policy.clamp.models.acm.concepts.Participant; import org.onap.policy.clamp.models.acm.concepts.ParticipantDefinition; import org.onap.policy.clamp.models.acm.concepts.ParticipantReplica; @@ -109,7 +110,8 @@ public class SupervisionParticipantHandler { participantStatusMsg.getParticipantSupportedElementType(), false); if (!participantStatusMsg.getAutomationCompositionInfoList().isEmpty()) { - automationCompositionProvider.upgradeStates(participantStatusMsg.getAutomationCompositionInfoList()); + updateAcOutProperties(participantStatusMsg.getAutomationCompositionInfoList(), + participantStatusMsg.getCompositionId()); } if (!participantStatusMsg.getParticipantDefinitionUpdates().isEmpty() && participantStatusMsg.getCompositionId() != null) { @@ -150,6 +152,16 @@ public class SupervisionParticipantHandler { } + private void updateAcOutProperties(List<AutomationCompositionInfo> automationCompositionInfoList, + UUID compositionId) { + automationCompositionProvider.upgradeStates(automationCompositionInfoList); + var acDefinition = acDefinitionProvider.getAcDefinition(compositionId); + for (var acInfo : automationCompositionInfoList) { + var ac = automationCompositionProvider.getAutomationComposition(acInfo.getAutomationCompositionId()); + participantSyncPublisher.sendSync(acDefinition.getServiceTemplate(), ac); + } + } + private void updateAcDefinitionOutProperties(UUID compositionId, UUID replicaId, List<ParticipantDefinition> list) { var acDefinitionOpt = acDefinitionProvider.findAcDefinition(compositionId); if (acDefinitionOpt.isEmpty()) { |