diff options
Diffstat (limited to 'catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/instance/ComponentInstanceChangeOperationOrchestrator.java')
-rw-r--r-- | catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/instance/ComponentInstanceChangeOperationOrchestrator.java | 27 |
1 files changed, 14 insertions, 13 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/instance/ComponentInstanceChangeOperationOrchestrator.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/instance/ComponentInstanceChangeOperationOrchestrator.java index e631e9f728..fa1211d8ab 100644 --- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/instance/ComponentInstanceChangeOperationOrchestrator.java +++ b/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/instance/ComponentInstanceChangeOperationOrchestrator.java @@ -7,9 +7,9 @@ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -17,18 +17,16 @@ * limitations under the License. * ============LICENSE_END========================================================= */ - package org.openecomp.sdc.be.components.impl.instance; +import java.util.Iterator; +import java.util.List; +import java.util.function.Function; import org.openecomp.sdc.be.dao.api.ActionStatus; import org.openecomp.sdc.be.model.Component; import org.openecomp.sdc.be.model.ComponentInstance; import org.openecomp.sdc.common.log.wrappers.Logger; -import java.util.Iterator; -import java.util.List; -import java.util.function.Function; - @org.springframework.stereotype.Component public class ComponentInstanceChangeOperationOrchestrator { @@ -40,24 +38,27 @@ public class ComponentInstanceChangeOperationOrchestrator { } public ActionStatus doPostChangeVersionOperations(Component container, ComponentInstance prevVersion, ComponentInstance newVersion) { - log.debug("#doPostChangeVersionOperations - starting post change version operations for component {}. from instance {} to instance {}", container.getUniqueId(), prevVersion.getUniqueId(), newVersion.getUniqueId()); - Function<OnComponentInstanceChangeOperation, ActionStatus> instanceChangeTaskRunner = operation -> operation.onChangeVersion(container, prevVersion, newVersion); + log.debug("#doPostChangeVersionOperations - starting post change version operations for component {}. from instance {} to instance {}", + container.getUniqueId(), prevVersion.getUniqueId(), newVersion.getUniqueId()); + Function<OnComponentInstanceChangeOperation, ActionStatus> instanceChangeTaskRunner = operation -> operation + .onChangeVersion(container, prevVersion, newVersion); return doOnChangeInstanceOperations(instanceChangeTaskRunner); } public ActionStatus doOnDeleteInstanceOperations(Component container, String deletedInstanceId) { - log.debug("#doPostChangeVersionOperations - starting on delete instance operations for component {} and instance {}.", container.getUniqueId(), deletedInstanceId); - Function<OnComponentInstanceChangeOperation, ActionStatus> instanceChangeTaskRunner = operation -> operation.onDelete(container, deletedInstanceId); + log.debug("#doPostChangeVersionOperations - starting on delete instance operations for component {} and instance {}.", + container.getUniqueId(), deletedInstanceId); + Function<OnComponentInstanceChangeOperation, ActionStatus> instanceChangeTaskRunner = operation -> operation + .onDelete(container, deletedInstanceId); return doOnChangeInstanceOperations(instanceChangeTaskRunner); } private ActionStatus doOnChangeInstanceOperations(Function<OnComponentInstanceChangeOperation, ActionStatus> instanceChangeTaskRunner) { ActionStatus onDeleteInstanceResult = ActionStatus.OK; Iterator<OnComponentInstanceChangeOperation> onDeleteInstIter = onInstanceChangeOperations.iterator(); - while(onDeleteInstIter.hasNext() && onDeleteInstanceResult == ActionStatus.OK) { + while (onDeleteInstIter.hasNext() && onDeleteInstanceResult == ActionStatus.OK) { onDeleteInstanceResult = instanceChangeTaskRunner.apply(onDeleteInstIter.next()); } return onDeleteInstanceResult; } - } |