@Test public void testStandardInitNoExc() throws Exception { consumer.init(); }
@Override public void init() throws CoreException { if (!(retrieveConsumer() instanceof FsConsumerImpl)) throw new CoreException("You cannot configure a file system event poller with any non file system consumer."); else { if (retrieveConsumer(FsConsumerImpl.class).getQuietInterval() == null) throw new CoreException("With the immediate file system poller, you must configure a quiet period for the FsConsumer"); } monitorThread = createThread(); }
FsImmediateEventPoller extends PollerImp { @Override public void init() throws CoreException { if (!(retrieveConsumer() instanceof FsConsumerImpl)) throw new CoreException("You cannot configure a file system event poller with any non file system consumer."); else { if (retrieveConsumer(FsConsumerImpl.class).getQuietInterval() == null) throw new CoreException("With the immediate file system poller, you must configure a quiet period for the FsConsumer"); } monitorThread = createThread(); } }
FsImmediateEventPoller extends PollerImp { @Override public void init() throws CoreException { if (!(retrieveConsumer() instanceof FsConsumerImpl)) throw new CoreException("You cannot configure a file system event poller with any non file system consumer."); else { if (retrieveConsumer(FsConsumerImpl.class).getQuietInterval() == null) throw new CoreException("With the immediate file system poller, you must configure a quiet period for the FsConsumer"); } monitorThread = createThread(); } FsImmediateEventPoller(); }
FsImmediateEventPoller extends PollerImp { @Override public void init() throws CoreException { if (!(retrieveConsumer() instanceof FsConsumerImpl)) throw new CoreException("You cannot configure a file system event poller with any non file system consumer."); else { if (retrieveConsumer(FsConsumerImpl.class).getQuietInterval() == null) throw new CoreException("With the immediate file system poller, you must configure a quiet period for the FsConsumer"); } monitorThread = createThread(); } FsImmediateEventPoller(); @Override void init(); @Override void start(); @Override void stop(); @Override void close(); TimeInterval getCreationCompleteCheck(); void setCreationCompleteCheck(TimeInterval t); }
FsImmediateEventPoller extends PollerImp { @Override public void init() throws CoreException { if (!(retrieveConsumer() instanceof FsConsumerImpl)) throw new CoreException("You cannot configure a file system event poller with any non file system consumer."); else { if (retrieveConsumer(FsConsumerImpl.class).getQuietInterval() == null) throw new CoreException("With the immediate file system poller, you must configure a quiet period for the FsConsumer"); } monitorThread = createThread(); } FsImmediateEventPoller(); @Override void init(); @Override void start(); @Override void stop(); @Override void close(); TimeInterval getCreationCompleteCheck(); void setCreationCompleteCheck(TimeInterval t);  }