}
@Override
- public ListenableFuture<RpcResult<CancelResourceReserveOutput>>
- cancelResourceReserve(CancelResourceReserveInput input) {
+ public ListenableFuture<RpcResult<CancelResourceReserveOutput>> cancelResourceReserve(
+ CancelResourceReserveInput input) {
// TODO Auto-generated method stub
return null;
}
}
@Override
- public ListenableFuture<RpcResult<PathComputationRequestOutput>>
- pathComputationRequest(PathComputationRequestInput input) {
+ public ListenableFuture<RpcResult<PathComputationRequestOutput>> pathComputationRequest(
+ PathComputationRequestInput input) {
// TODO Auto-generated method stub
return null;
}
return null;
}
- @Override public ListenableFuture<RpcResult<ServicePowerResetOutput>>
- servicePowerReset(ServicePowerResetInput input) {
+ @Override public ListenableFuture<RpcResult<ServicePowerResetOutput>> servicePowerReset(
+ ServicePowerResetInput input) {
return null;
}
- @Override public ListenableFuture<RpcResult<ServicePowerSetupOutput>>
- servicePowerSetup(ServicePowerSetupInput input) {
+ @Override public ListenableFuture<RpcResult<ServicePowerSetupOutput>> servicePowerSetup(
+ ServicePowerSetupInput input) {
return RpcResultBuilder.success(new ServicePowerSetupOutputBuilder().build()).buildFuture();
}
}
package org.opendaylight.transportpce.renderer.utils;
+import com.google.common.util.concurrent.ListenableFuture;
import java.util.List;
import java.util.Optional;
-import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import org.mockito.Mockito;
GetConnectionPortTrailOutputBuilder getConnectionPortTrailOutputBuilder =
new GetConnectionPortTrailOutputBuilder();
getConnectionPortTrailOutputBuilder.setPorts(ports);
- RpcResultBuilder<GetConnectionPortTrailOutput> rpcResultBuilder =
- RpcResultBuilder.success(getConnectionPortTrailOutputBuilder.build());
- Future<RpcResult<GetConnectionPortTrailOutput>> rpcResultFuture =
- CompletableFuture.completedFuture(rpcResultBuilder.build());
+ ListenableFuture<RpcResult<GetConnectionPortTrailOutput>> rpcResultFuture =
+ RpcResultBuilder.success(getConnectionPortTrailOutputBuilder.build()).buildFuture();
Mockito.doReturn(rpcResultFuture).when(orgOpenroadmDeviceService).getConnectionPortTrail(Mockito.any());
Mockito.doReturn(orgOpenroadmDeviceService).when(rpcConsumerRegistry).getRpcService(Mockito.any());
MountPointStub mountPoint = new MountPointStub(dataBroker);