X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=renderer%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Frenderer%2Fprovisiondevice%2Ftasks%2FOlmPowerSetupTask.java;h=1f1badc54b7785c96d2f926989bf7cb3520b50b5;hb=b1b3bafd549bb501937cea5c976d5344608b6ed3;hp=5d4f3f72082ef62ba56e3c06edea6de5a4fe26a8;hpb=82610815f1b706e2f9b5e5578474f3a8205c41aa;p=transportpce.git diff --git a/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/OlmPowerSetupTask.java b/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/OlmPowerSetupTask.java index 5d4f3f720..1f1badc54 100644 --- a/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/OlmPowerSetupTask.java +++ b/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/OlmPowerSetupTask.java @@ -7,12 +7,15 @@ */ package org.opendaylight.transportpce.renderer.provisiondevice.tasks; +import static java.util.Objects.requireNonNull; + import java.util.concurrent.Callable; import java.util.concurrent.Future; +import org.opendaylight.transportpce.common.ResponseCodes; import org.opendaylight.transportpce.renderer.provisiondevice.OLMRenderingResult; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupInput; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupOutput; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.TransportpceOlmService; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetup; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupInput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupOutput; import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -21,17 +24,17 @@ public class OlmPowerSetupTask implements Callable { private static final Logger LOG = LoggerFactory.getLogger(OlmPowerSetupTask.class); - private final TransportpceOlmService olmService; + private final ServicePowerSetup servicePowerSetup; private final ServicePowerSetupInput input; - public OlmPowerSetupTask(TransportpceOlmService olmService, ServicePowerSetupInput input) { - this.olmService = olmService; + public OlmPowerSetupTask(ServicePowerSetup servicePowerSetup, ServicePowerSetupInput input) { + this.servicePowerSetup = requireNonNull(servicePowerSetup); this.input = input; } @Override public OLMRenderingResult call() throws Exception { - Future> fr = this.olmService.servicePowerSetup(this.input); + Future> fr = servicePowerSetup.invoke(this.input); RpcResult result = fr.get(); if (result == null) { LOG.warn("Result is NULL"); @@ -39,7 +42,7 @@ public class OlmPowerSetupTask implements Callable { } LOG.debug("Result: {}", result.getResult()); - if (result.isSuccessful()) { + if (ResponseCodes.SUCCESS_RESULT.equals(result.getResult().getResult())) { LOG.info("OLM power setup finished successfully"); return OLMRenderingResult.ok(); } else {