info.magnolia.dirwatch

Class DirectoryWatcher

java.lang.Object

info.magnolia.dirwatch.DirectoryWatcher

All Implemented Interfaces:

Runnable

public class DirectoryWatcher
extends Object
implements Runnable

The DirectoryWatcher covers implementation of the low level WatchService API.

Highly inspired by http://docs.oracle.com/javase/tutorial/displayCode.html?code=http://docs.oracle.com/javase/tutorial/essential/io/examples/WatchDir.java Since java.nio.file.Watch* is not guaranteed to be using native events, we'll probably want to extract an interface for this. (non-native implementations use polling and can be quite slow) JDK on OSX doesn't have a native impl for 7 or 8: https://bugs.openjdk.java.net/browse/JDK-7133447 See http://wiki.netbeans.org/NativeFileNotifications https://code.google.com/p/barbarywatchservice/

Constructor Summary

Constructors

Constructor and Description
DirectoryWatcher(boolean recursive, boolean followLinks)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	processEvent(WatchEvent.Kind<?> kind, Path completePath, WatchEvent<?> watchEvent) Process given pending WatchEvent as needed.
void	register(Path dir, com.google.common.base.Predicate<Path> filterPredicate, WatcherCallback callback)
protected void	registerDirectory(Path dir) Register the given directory with the WatchService.
protected void	registerRecursively(Path start, com.google.common.base.Predicate<Path> filterPredicate) Register the given directory, and all its sub-directories, with the WatchService.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectoryWatcher

public DirectoryWatcher(boolean recursive,
                boolean followLinks)
                 throws IOException

Throws:

IOException

Method Detail

register

public void register(Path dir,
            com.google.common.base.Predicate<Path> filterPredicate,
            WatcherCallback callback)
              throws IOException

Throws:

IOException

registerDirectory

protected void registerDirectory(Path dir)
                          throws IOException

Register the given directory with the WatchService.

Throws:

IOException

registerRecursively

protected void registerRecursively(Path start,
                       com.google.common.base.Predicate<Path> filterPredicate)
                            throws IOException

Register the given directory, and all its sub-directories, with the WatchService.

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

processEvent

protected void processEvent(WatchEvent.Kind<?> kind,
                Path completePath,
                WatchEvent<?> watchEvent)

Process given pending WatchEvent as needed.

Parameters:

kind - the event kind

completePath - an absolute Path where the event occurred

watchEvent - the raw event for further custom processing