@Test(expected = WorkerspaceQueueException.class) public void whenTransferThenKO() throws WorkerspaceQueueException { HandlerIO handlerIO = mock(HandlerIOImpl.class); AsyncWorkspaceTransfer async = new AsyncWorkspaceTransfer(handlerIO); async.transfer(null); }
public void transfer(WorkspaceQueue workspaceQueue) throws WorkerspaceQueueException { if (null == runner) { throw new WorkerspaceQueueException("Workspace batch runner is not started, call startTransfer to start it"); } this.runner.transfer(workspaceQueue); }
AsyncWorkspaceTransfer { public void transfer(WorkspaceQueue workspaceQueue) throws WorkerspaceQueueException { if (null == runner) { throw new WorkerspaceQueueException("Workspace batch runner is not started, call startTransfer to start it"); } this.runner.transfer(workspaceQueue); } }
AsyncWorkspaceTransfer { public void transfer(WorkspaceQueue workspaceQueue) throws WorkerspaceQueueException { if (null == runner) { throw new WorkerspaceQueueException("Workspace batch runner is not started, call startTransfer to start it"); } this.runner.transfer(workspaceQueue); } AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO); }
AsyncWorkspaceTransfer { public void transfer(WorkspaceQueue workspaceQueue) throws WorkerspaceQueueException { if (null == runner) { throw new WorkerspaceQueueException("Workspace batch runner is not started, call startTransfer to start it"); } this.runner.transfer(workspaceQueue); } AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO); void transfer(WorkspaceQueue workspaceQueue); void startTransfer(int queueSize); void waitEndOfTransfer(); }
AsyncWorkspaceTransfer { public void transfer(WorkspaceQueue workspaceQueue) throws WorkerspaceQueueException { if (null == runner) { throw new WorkerspaceQueueException("Workspace batch runner is not started, call startTransfer to start it"); } this.runner.transfer(workspaceQueue); } AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO); void transfer(WorkspaceQueue workspaceQueue); void startTransfer(int queueSize); void waitEndOfTransfer();  }