Package org.chenile.filewatch.handler

Class FileWatcherExecutorService

java.lang.Object

org.chenile.filewatch.handler.FileWatcherExecutorService

public class FileWatcherExecutorService
extends Object

The main file for file watch This allows the handler to register FileWatchDefinition. It also starts the file watch by executing the FileWatcher in a separate thread. Once a file is discovered by the file watcher, this class picks it up and hands it over to the fileProcessor for further processing.

Author:

Raja Shankar Kolluru

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	FileWatcherExecutorService.WatchInfo

Field Summary

Fields

Modifier and Type	Field	Description
protected String	baseProcessedFolder
protected String	baseWatchFolder
protected ExecutorService	executorService
private FileProcessor	fileProcessor
private FileSystem	fileSystem	Ability to inject a file system facilitates mocking
protected int	pollTimeInSeconds
private WatchService	watcher
private Map<WatchKey,FileWatcherExecutorService.WatchInfo>	watchKeyToInfoMap

Constructor Summary

Constructors

Constructor	Description
FileWatcherExecutorService(String baseWatchFolder, String baseProcessedFolder, int pollTimeInSeconds, FileSystem fileSystem)

Method Summary

Modifier and Type	Method	Description
void	handleFile(WatchKey key, Path fileSeen)	This will be the callback for every file that has been discovered by the FileWatcher
private void	processExisting(FileWatchDefinition fileWatchDefinition, Path watchDir, Path processedDir)
void	registerWatch(FileWatchDefinition fileWatchDefinition)
void	startWatch()

Methods inherited from class java.lang.Object

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

Field Details

baseWatchFolder

protected String baseWatchFolder

baseProcessedFolder

protected String baseProcessedFolder

pollTimeInSeconds

protected int pollTimeInSeconds

executorService

@Autowired
protected ExecutorService executorService

watcher

private WatchService watcher

fileProcessor

@Autowired
private FileProcessor fileProcessor

fileSystem

private FileSystem fileSystem

Ability to inject a file system facilitates mocking

watchKeyToInfoMap

private Map<WatchKey,FileWatcherExecutorService.WatchInfo> watchKeyToInfoMap

Constructor Details

FileWatcherExecutorService

public FileWatcherExecutorService(String baseWatchFolder,
 String baseProcessedFolder,
 int pollTimeInSeconds,
 FileSystem fileSystem)

Method Details

registerWatch

public void registerWatch(FileWatchDefinition fileWatchDefinition)

processExisting

private void processExisting(FileWatchDefinition fileWatchDefinition,
 Path watchDir,
 Path processedDir)

startWatch

public void startWatch()

handleFile

public void handleFile(WatchKey key,
 Path fileSeen)

This will be the callback for every file that has been discovered by the FileWatcher

Parameters:

key -

fileSeen -