com.github.cafdataprocessing.utilities.tasksubmitter.monitor

Class DirectoryWatcher

java.lang.Object

com.github.cafdataprocessing.utilities.tasksubmitter.monitor.DirectoryWatcher

public class DirectoryWatcher
extends Object

Tasked with setting up a watch on a directory for new files and perform a provided action. The watch will run in a separate thread.

Constructor Summary

Constructors

Constructor and Description
DirectoryWatcher()

Method Summary

Modifier and Type	Method and Description
static ExecutorService	watchDirectoryForNewFiles(String directoryPathStr, Consumer<org.apache.commons.vfs2.FileObject> eventFunction) Watches a given directory for new files being added to it and when they are executes the provided function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DirectoryWatcher

public DirectoryWatcher()

Method Detail

watchDirectoryForNewFiles

public static ExecutorService watchDirectoryForNewFiles(String directoryPathStr,
                                                        Consumer<org.apache.commons.vfs2.FileObject> eventFunction)
                                                 throws IOException

Watches a given directory for new files being added to it and when they are executes the provided function.

Parameters:

directoryPathStr - The directory to watch.

eventFunction - Function to execute when new files added to the directory. Path of new file will be passed to function.

Returns:

The Executor Service used in monitoring the folder.

Throws:

IOException - If unable to resolve the filepath provided.