X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=renderer%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Frenderer%2Frpcs%2FDeviceRendererRPCImpl.java;h=0edd950b3c6f46747e40282f5b2f9887b4ea5127;hb=refs%2Fchanges%2F96%2F74296%2F7;hp=f5c35496ff34c3f11e06c6138e53105c3c221e69;hpb=80f9070187cb60c40f057df83bd2ecd123b84b5d;p=transportpce.git diff --git a/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java b/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java index f5c35496f..0edd950b3 100644 --- a/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java +++ b/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java @@ -8,8 +8,7 @@ package org.opendaylight.transportpce.renderer.rpcs; -import java.util.concurrent.Future; - +import com.google.common.util.concurrent.ListenableFuture; import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRendererService; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackOutput; @@ -56,13 +55,13 @@ public class DeviceRendererRPCImpl implements RendererService { * @return Result of the request */ @Override - public Future> servicePath(ServicePathInput input) { + public ListenableFuture> servicePath(ServicePathInput input) { if (input.getOperation().getIntValue() == 1) { LOG.info("Create operation request received"); - return RpcResultBuilder.success(deviceRenderer.setupServicePath(input, null)).buildFuture(); + return RpcResultBuilder.success(this.deviceRenderer.setupServicePath(input, null)).buildFuture(); } else if (input.getOperation().getIntValue() == 2) { LOG.info("Delete operation request received"); - return RpcResultBuilder.success(deviceRenderer.deleteServicePath(input)).buildFuture(); + return RpcResultBuilder.success(this.deviceRenderer.deleteServicePath(input)).buildFuture(); } return RpcResultBuilder.success(new ServicePathOutputBuilder().setResult("Invalid operation")).buildFuture(); } @@ -74,7 +73,7 @@ public class DeviceRendererRPCImpl implements RendererService { * @return Success flag and nodes which failed to rollback */ @Override - public Future> rendererRollback(RendererRollbackInput input) { - return RpcResultBuilder.success(deviceRenderer.rendererRollback(input)).buildFuture(); + public ListenableFuture> rendererRollback(RendererRollbackInput input) { + return RpcResultBuilder.success(this.deviceRenderer.rendererRollback(input)).buildFuture(); } }