org.datadog.watcher

Class FileWatcherImpl

java.lang.Object

org.datadog.watcher.FileWatcherImpl

All Implemented Interfaces:

Closeable, AutoCloseable, ResourceWatcher

public class FileWatcherImpl
extends Object
implements ResourceWatcher

A file ResourceWatcher implemnatation. It watches a file and detects any new modification. The file content that already exist before the watcher is launched is skipped. Only file content addition is handled.

Constructor Summary

Constructors

Constructor and Description
FileWatcherImpl(WatchService watchService, Path filePath, OutputHandler outputHandler)

Method Summary

Modifier and Type	Method and Description
void	close()
void	run() Launches a WatchService and register the file's parent directory for events of type StandardWatchEventKinds.ENTRY_MODIFY.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileWatcherImpl

@Inject
public FileWatcherImpl(@NonNull
                                WatchService watchService,
                                @NonNull
                                Path filePath,
                                @NonNull
                                OutputHandler outputHandler)

Method Detail

run

public void run()

Launches a WatchService and register the file's parent directory for events of type StandardWatchEventKinds.ENTRY_MODIFY. The events are filtered according to the filename. Only the file modications are handler. A first step consists of couting the existing characters already present in the file before registering the file for watching the modificatiion events. At each modification event the existing characters are skipped and only the new added lines are processed.

Specified by:

run in interface ResourceWatcher

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable