src/main/java/com/mqtt/client/publisher/dirlistener/listener/CamRecording.java
public boolean processEvents() {
        // wait for key to be signaled
        try {

            this.key = watcher.take();

        } catch (InterruptedException x) {

            x.printStackTrace();

            return true;

        }

        if (this.loopPolledEvents()) {

            return true;
        }

        // Reset the key -- this step is critical if you want to receive
        // further watch events. If the key is no longer valid, the directory
        // is inaccessible so exit the loop.
        boolean valid = key.reset();

        if (!valid) {

            return this.processEvents();

        }

        return this.processEvents();
    }
/**
     * Process all events for the key queued to the watcher.
     */
Process all events for the key queued to the watcher.
Process all events for the key queued to the watcher .
public boolean processEvents() {
        try {
            this.key = watcher.take();
        } catch (InterruptedException x) {
            x.printStackTrace();
            return true;
        }
        if (this.loopPolledEvents()) {
            return true;
        }
        boolean valid = key.reset();
        if (!valid) {
            return this.processEvents();
        }
        return this.processEvents();
    }
public boolean processEvents ( ) { try { this . key = watcher . take ( ) ; } catch ( InterruptedException x ) { x . printStackTrace ( ) ; return true ; } if ( this . loopPolledEvents ( ) ) { return true ; } boolean valid = key . reset ( ) ; if ( ! valid ) { return this . processEvents ( ) ; } return this . processEvents ( ) ; }
Process all events for the key queued to the watcher.
Process all events for the key queued to the watcher .
// wait for key to be signaled // Reset the key -- this step is critical if you want to receive // further watch events. If the key is no longer valid, the directory // is inaccessible so exit the loop.