@Test public void mongoDataUpdate_emptyDataSet() throws Exception { DataMigrationService instance = new DataMigrationService(dataMigrationRepository, graphLoader); instance.mongoDataUpdate(); awaitTermination(instance); assertThat(MetadataCollections.UNIT.getCollection().find().iterator().hasNext()).isFalse(); }
void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } DataMigrationService(); @VisibleForTesting  DataMigrationService(DataMigrationRepository dataMigrationRepository, GraphLoader graphLoader); }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } DataMigrationService(); @VisibleForTesting  DataMigrationService(DataMigrationRepository dataMigrationRepository, GraphLoader graphLoader); boolean isMongoDataUpdateInProgress(); boolean tryStartMongoDataUpdate(); }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } DataMigrationService(); @VisibleForTesting  DataMigrationService(DataMigrationRepository dataMigrationRepository, GraphLoader graphLoader); boolean isMongoDataUpdateInProgress(); boolean tryStartMongoDataUpdate();  }