@Test public void testCallProcessNotFound() { LongRunningProcessPingTask pingTask = createTask(UUID.randomUUID()); List<LongRunningProcessStatus> statuses = pingTask.call(); assertEquals(1, statuses.size()); LongRunningProcessStatus status = statuses.get(0); assertEquals(LongRunningProcessState.NOT_FOUND, status.getState()); assertNull(status.getException()); assertEquals(0, metadataStorage.size()); }
@Override public List<LongRunningProcessStatus> call() { ArrayList<LongRunningProcessStatus> statuses = new ArrayList<>(); for (UUID procId : procIds) statuses.add(getProcessStatus(procId)); return statuses; }
LongRunningProcessPingTask extends LongRunningProcessTask<List<LongRunningProcessStatus>> { @Override public List<LongRunningProcessStatus> call() { ArrayList<LongRunningProcessStatus> statuses = new ArrayList<>(); for (UUID procId : procIds) statuses.add(getProcessStatus(procId)); return statuses; } }
LongRunningProcessPingTask extends LongRunningProcessTask<List<LongRunningProcessStatus>> { @Override public List<LongRunningProcessStatus> call() { ArrayList<LongRunningProcessStatus> statuses = new ArrayList<>(); for (UUID procId : procIds) statuses.add(getProcessStatus(procId)); return statuses; } LongRunningProcessPingTask(List<UUID> procIds); }
LongRunningProcessPingTask extends LongRunningProcessTask<List<LongRunningProcessStatus>> { @Override public List<LongRunningProcessStatus> call() { ArrayList<LongRunningProcessStatus> statuses = new ArrayList<>(); for (UUID procId : procIds) statuses.add(getProcessStatus(procId)); return statuses; } LongRunningProcessPingTask(List<UUID> procIds); @Override List<LongRunningProcessStatus> call(); }
LongRunningProcessPingTask extends LongRunningProcessTask<List<LongRunningProcessStatus>> { @Override public List<LongRunningProcessStatus> call() { ArrayList<LongRunningProcessStatus> statuses = new ArrayList<>(); for (UUID procId : procIds) statuses.add(getProcessStatus(procId)); return statuses; } LongRunningProcessPingTask(List<UUID> procIds); @Override List<LongRunningProcessStatus> call();  }