AbstractResumeBreakPointManager implements ResumeBreakPointManager, Closeable { protected final void resumeIncrementalPosition(final String data) { if (Strings.isNullOrEmpty(data)) { return; } log.info("resume incremental position from {} = {}", taskPath, data); Map<String, Object> incrementalPosition = GSON.<Map<String, Object>>fromJson(data, Map.class); for (Entry<String, Object> entry : incrementalPosition.entrySet()) { incrementalPositionManagerMap.put(entry.getKey(), PositionManagerFactory.newInstance(databaseType, entry.getValue().toString())); } }  @Override void close();  }
@Test public void assertResumeInventoryPosition() { resumeBreakPointManager.resumeIncrementalPosition(""); assertThat(resumeBreakPointManager.getIncrementalPositionManagerMap().size(), is(0)); resumeBreakPointManager.resumeIncrementalPosition(incrementalPosition); assertThat(resumeBreakPointManager.getIncrementalPositionManagerMap().size(), is(2)); }