RepositoryResumeBreakPointManager extends AbstractResumeBreakPointManager { @Override public void persistInventoryPosition() { String result = getInventoryPositionData(); registryRepository.persist(inventoryPath, result); log.info("persist inventory position {} = {}", inventoryPath, result); } RepositoryResumeBreakPointManager(final String databaseType, final String taskPath); static boolean isAvailable(); @Override void close(); @Override void persistInventoryPosition(); @Override void persistIncrementalPosition();  }
@Test public void assertPersistInventoryPosition() { repositoryResumeBreakPointManager.persistInventoryPosition(); verify(registryRepository, atLeastOnce()).persist("/base/inventory", "{\"unfinished\":{},\"finished\":[]}"); }