@Test public void testStop() throws Exception { }
public void stop() { try { if(alive) { LOG.info("Starting Context Monitor for File : " + source.getAbsolutePath()); reader.stop(); } else { LOG.warning("Not stopped since not alive. File: " + source.getAbsolutePath()); } } finally { alive = false; } }
FileEntrySource implements IOEntrySource { public void stop() { try { if(alive) { LOG.info("Starting Context Monitor for File : " + source.getAbsolutePath()); reader.stop(); } else { LOG.warning("Not stopped since not alive. File: " + source.getAbsolutePath()); } } finally { alive = false; } } }
FileEntrySource implements IOEntrySource { public void stop() { try { if(alive) { LOG.info("Starting Context Monitor for File : " + source.getAbsolutePath()); reader.stop(); } else { LOG.warning("Not stopped since not alive. File: " + source.getAbsolutePath()); } } finally { alive = false; } } FileEntrySource(File source); }
FileEntrySource implements IOEntrySource { public void stop() { try { if(alive) { LOG.info("Starting Context Monitor for File : " + source.getAbsolutePath()); reader.stop(); } else { LOG.warning("Not stopped since not alive. File: " + source.getAbsolutePath()); } } finally { alive = false; } } FileEntrySource(File source); void setName(String name); void reset(); IOEntrySource createNew(); String getName(); void start(); void stop(); String getId(); boolean isAlive(); void addListener(EntryReadListener listener); void removeListener(EntryReadListener listener); boolean isRestartable(); String getWatchedAddr(); }
FileEntrySource implements IOEntrySource { public void stop() { try { if(alive) { LOG.info("Starting Context Monitor for File : " + source.getAbsolutePath()); reader.stop(); } else { LOG.warning("Not stopped since not alive. File: " + source.getAbsolutePath()); } } finally { alive = false; } } FileEntrySource(File source); void setName(String name); void reset(); IOEntrySource createNew(); String getName(); void start(); void stop(); String getId(); boolean isAlive(); void addListener(EntryReadListener listener); void removeListener(EntryReadListener listener); boolean isRestartable(); String getWatchedAddr();  }