diff options
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()) { |