@Test public void test_ProcessJobs_EmptyList() throws InterruptedException, MalformedURLException, TimeoutException, ExecutionException, UnknownHostException { harvesterDao.saveProcessingJobTuples(Collections.EMPTY_LIST, migrationBatchId); assertEquals(0, dataStore.getCount(ProcessingJob.class)); }
public void saveProcessingJobTuples (List<ProcessingJobTuple> processingJobTuples, String migratingBatchId) throws InterruptedException, MalformedURLException, TimeoutException, ExecutionException, UnknownHostException { harvesterClient.createOrModifyProcessingJobTuples(processingJobTuples); }
MigratorHarvesterDao { public void saveProcessingJobTuples (List<ProcessingJobTuple> processingJobTuples, String migratingBatchId) throws InterruptedException, MalformedURLException, TimeoutException, ExecutionException, UnknownHostException { harvesterClient.createOrModifyProcessingJobTuples(processingJobTuples); } }
MigratorHarvesterDao { public void saveProcessingJobTuples (List<ProcessingJobTuple> processingJobTuples, String migratingBatchId) throws InterruptedException, MalformedURLException, TimeoutException, ExecutionException, UnknownHostException { harvesterClient.createOrModifyProcessingJobTuples(processingJobTuples); } MigratorHarvesterDao(MongoConfig mongoConfig); }
MigratorHarvesterDao { public void saveProcessingJobTuples (List<ProcessingJobTuple> processingJobTuples, String migratingBatchId) throws InterruptedException, MalformedURLException, TimeoutException, ExecutionException, UnknownHostException { harvesterClient.createOrModifyProcessingJobTuples(processingJobTuples); } MigratorHarvesterDao(MongoConfig mongoConfig); void saveProcessingJobTuples(List<ProcessingJobTuple> processingJobTuples, String migratingBatchId); }
MigratorHarvesterDao { public void saveProcessingJobTuples (List<ProcessingJobTuple> processingJobTuples, String migratingBatchId) throws InterruptedException, MalformedURLException, TimeoutException, ExecutionException, UnknownHostException { harvesterClient.createOrModifyProcessingJobTuples(processingJobTuples); } MigratorHarvesterDao(MongoConfig mongoConfig); void saveProcessingJobTuples(List<ProcessingJobTuple> processingJobTuples, String migratingBatchId);  }