RepositoryResumeBreakPointManager extends AbstractResumeBreakPointManager { @Override public void persistIncrementalPosition() { String result = getIncrementalPositionData(); registryRepository.persist(incrementalPath, result); log.info("persist incremental position {} = {}", incrementalPath, result); } RepositoryResumeBreakPointManager(final String databaseType, final String taskPath); static boolean isAvailable(); @Override void close(); @Override void persistInventoryPosition(); @Override void persistIncrementalPosition();  }
@Test public void assertPersistIncrementalPosition() { repositoryResumeBreakPointManager.persistIncrementalPosition(); verify(registryRepository, atLeastOnce()).persist("/base/incremental", "{}"); }