diff options
Diffstat (limited to 'participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler')
2 files changed, 6 insertions, 21 deletions
diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java index b4735f1c0..c7cb54893 100644..100755 --- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java +++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java @@ -29,6 +29,8 @@ import org.onap.policy.clamp.models.acm.concepts.AcElementDeploy; 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.AutomationCompositionElementDefinition; +import org.onap.policy.clamp.models.acm.concepts.DeployState; +import org.onap.policy.clamp.models.acm.concepts.LockState; import org.onap.policy.clamp.models.acm.concepts.ParticipantDeploy; import org.onap.policy.clamp.models.acm.concepts.ParticipantRestartAc; import org.onap.policy.clamp.models.acm.concepts.ParticipantUtils; @@ -264,6 +266,7 @@ public class AutomationCompositionHandler { int startPhase = ParticipantUtils.findStartPhase( cacheProvider.getCommonProperties(automationComposition.getInstanceId(), acElement.getId())); if (startPhaseMsg.equals(startPhase)) { + acElement.setDeployState(DeployState.UNDEPLOYING); listener.undeploy(messageId, automationComposition.getInstanceId(), acElement.getId()); } } @@ -275,6 +278,7 @@ public class AutomationCompositionHandler { int startPhase = ParticipantUtils.findStartPhase( cacheProvider.getCommonProperties(automationComposition.getInstanceId(), acElement.getId())); if (startPhaseMsg.equals(startPhase)) { + acElement.setDeployState(DeployState.DELETING); listener.delete(messageId, automationComposition.getInstanceId(), acElement.getId()); } } @@ -293,6 +297,7 @@ public class AutomationCompositionHandler { int startPhase = ParticipantUtils.findStartPhase( cacheProvider.getCommonProperties(automationComposition.getInstanceId(), acElement.getId())); if (startPhaseMsg.equals(startPhase)) { + acElement.setLockState(LockState.LOCKING); listener.lock(messageId, automationComposition.getInstanceId(), acElement.getId()); } } @@ -311,6 +316,7 @@ public class AutomationCompositionHandler { int startPhase = ParticipantUtils.findStartPhase( cacheProvider.getCommonProperties(automationComposition.getInstanceId(), acElement.getId())); if (startPhaseMsg.equals(startPhase)) { + acElement.setLockState(LockState.UNLOCKING); listener.unlock(messageId, automationComposition.getInstanceId(), acElement.getId()); } } diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ParticipantHandler.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ParticipantHandler.java index 8d906c07b..6b025c78c 100755 --- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ParticipantHandler.java +++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ParticipantHandler.java @@ -29,7 +29,6 @@ import lombok.RequiredArgsConstructor; import org.onap.policy.clamp.acm.participant.intermediary.comm.ParticipantMessagePublisher; import org.onap.policy.clamp.models.acm.concepts.AcTypeState; import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElementDefinition; -import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionInfo; import org.onap.policy.clamp.models.acm.concepts.ParticipantState; import org.onap.policy.clamp.models.acm.messages.dmaap.participant.AutomationCompositionDeploy; import org.onap.policy.clamp.models.acm.messages.dmaap.participant.AutomationCompositionStateChange; @@ -236,24 +235,4 @@ public class ParticipantHandler { return heartbeat; } - - /** - * get AutomationComposition Info List. - * - * @return list of AutomationCompositionInfo - */ - private List<AutomationCompositionInfo> getAutomationCompositionInfoList() { - List<AutomationCompositionInfo> automationCompositionInfoList = new ArrayList<>(); - for (var entry : cacheProvider.getAutomationCompositions().entrySet()) { - var acInfo = new AutomationCompositionInfo(); - acInfo.setAutomationCompositionId(entry.getKey()); - acInfo.setDeployState(entry.getValue().getDeployState()); - acInfo.setLockState(entry.getValue().getLockState()); - for (var element : entry.getValue().getElements().values()) { - acInfo.getElements().add(automationCompositionOutHandler.getAutomationCompositionElementInfo(element)); - } - automationCompositionInfoList.add(acInfo); - } - return automationCompositionInfoList; - } } |