- public void invokeRpcTest() {
-
- rpcManager.deviceConnected(mockedRequestContext);
-// when(mockedProviderContext.getRpcService(SalFlowService.class)).thenReturn(value);
+ public void invokeRpcTestExistsCapacityTest() throws InterruptedException, ExecutionException {
+ invokeRpcTestExistsCapacity(10, true);
+ invokeRpcTestExistsCapacity(0, false);
+ }
+
+ private void invokeRpcTestExistsCapacity(final int capacity, final boolean result) throws InterruptedException,
+ ExecutionException {
+ // TODO: how to invoke service remotely?
+ final RpcContextImpl rpcContext = new RpcContextImpl(mockedProviderContext, mockedDeviceContext);
+ when(mockedProviderContext.getRpcService(SalFlowService.class)).thenReturn(new SalFlowServiceImpl(rpcContext));
+ rpcContext.setRequestContextQuota(capacity);
+