DataSourceWatcher.java

package com.configuration;

import java.io.IOException;
import java.nio.file.FileSystems;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.WatchEvent;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;

import static java.nio.file.StandardWatchEventKinds.*;
import org.springframework.scheduling.annotation.Async;

public class DataSourceWatcher {

    private String path;
    private String file;
    private Thread thread;
    private WatchService watchService;

    @Async
    public void watchDirectory() throws IOException {
        DataSourceWatcher dataSourceWatcher = new DataSourceWatcher();
        watchService = FileSystems.getDefault().newWatchService();
        Path pathFile = Paths.get(path);
        pathFile.register(watchService, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY);
        thread = new Thread(() -> {
            WatchKey key = null;
            try {
                while ((key = watchService.take()) != null) {
                    Thread.sleep(500);
                    for (WatchEvent<?> event : key.pollEvents()) {
                        if(file.equals(event.context().toString())) {
                            //
                        }
                    }
                    key.reset();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
                Thread.currentThread().interrupt();
            } catch (Exception e) {
                e.printStackTrace();
            }
        });
        thread.start();
        Runtime.getRuntime().addShutdownHook(new Thread(dataSourceWatcher::stop));
    }

    public void stop() {
        thread.interrupt();
        try {
            watchService.close();
        } catch (IOException e) {
            System.out.println("Error cerrando el watch service " + e);
        }
    }

    /**
     * @return String return the path
     */
    public String getPath() {
        return path;
    }

    /**
     * @param path the path to set
     */
    public void setPath(String path) {
        this.path = path;
    }


    /**
     * @return String return the file
     */
    public String getFile() {
        return file;
    }

    /**
     * @param file the file to set
     */
    public void setFile(String file) {
        this.file = file;
    }
}