private void startGeneralJobConfigFileMonitor ( ) throws Exception { SchedulerUtils . addPathAlterationObserver ( this . pathAlterationDetector , this . listener , jobConfigFileDirPath ) ; this . pathAlterationDetector . start ( ) ; this . closer . register ( new Closeable ( ) { @ Override public void close ( ) throws IOException { try { pathAlterationDetector . stop ( 1000 ) ; } catch ( InterruptedException e ) { throw new IOException ( e ) ; } } } ) ; }
Start the job configuration file monitor using generic file system API .