org.thales.punch.libraries.storm.util

Class DirWatcher

java.lang.Object

java.util.TimerTask

org.thales.punch.libraries.storm.util.DirWatcher

All Implemented Interfaces:

Runnable

public abstract class DirWatcher
extends TimerTask

DirWatcher is a TimerTask class that periodically watch changes on a defined directory. Every detected file is put in a queue

Author:

Alex Piermatteo, Adrien Thébault

Constructor Summary

Constructors

Constructor and Description
DirWatcher(String path, String filter) Constructor of the class.
DirWatcher(String path, String filter, FileTime lastUpdate) Constructor of the class.

Method Summary

Modifier and Type	Method and Description
protected abstract void	onChange(File file, String action)
void	run() Run the thread.

Methods inherited from class java.util.TimerTask

cancel, scheduledExecutionTime

Methods inherited from class java.lang.Object

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

Constructor Detail

DirWatcher

public DirWatcher(String path,
                  String filter)

Constructor of the class.

Parameters:

path - directory path to watch

filter - detect changes only for filtered extensions

DirWatcher

public DirWatcher(String path,
                  String filter,
                  FileTime lastUpdate)

Constructor of the class.

Parameters:

filter - detect changes only for filtered extensions

path - directory path to watch

lastUpdate - last update time

Method Detail

run

public final void run()

Run the thread. Only files that have been modified during cycle N-1 and that have not been modified in the current cycle N are sent. This also ignores all the files that start with "ignore-""

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask

onChange

protected abstract void onChange(File file,
                                 String action)