io.micronaut.scheduling.io.watch.osx

Class MacOsWatchThread

java.lang.Object

io.micronaut.scheduling.io.watch.DefaultWatchThread

io.micronaut.scheduling.io.watch.osx.MacOsWatchThread

All Implemented Interfaces:

LifeCycle<DefaultWatchThread>, Closeable, AutoCloseable

@Replaces(value=DefaultWatchThread.class)
 @Parallel
 @Requires(property="micronaut.io.watch.enabled",value="true",defaultValue="true") @Requires(condition=FileWatchCondition.class) @Requires(classes={io.methvin.watchservice.MacOSXListeningWatchService.class,com.sun.jna.Library.class})
 @Singleton
public class MacOsWatchThread
extends DefaultWatchThread

Replaces the DefaultWatchThread for Mac OS X to use native file watch.

Since:

1.1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
MacOsWatchThread(ApplicationEventPublisher eventPublisher, FileWatchConfiguration configuration, WatchService watchService) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected void	closeWatchService() Closes the watch service.
protected WatchKey	registerPath(Path dir) Registers a patch to watch.

Methods inherited from class io.micronaut.scheduling.io.watch.DefaultWatchThread

close, getWatchService, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.context.LifeCycle

refresh

Constructor Detail

MacOsWatchThread

public MacOsWatchThread(ApplicationEventPublisher eventPublisher,
                        FileWatchConfiguration configuration,
                        WatchService watchService)

Default constructor.

Parameters:

eventPublisher - The event publisher

configuration - the configuration

watchService - the watch service

Method Detail

registerPath

@NonNull
protected WatchKey registerPath(@NonNull
                                         Path dir)
                                  throws IOException

Description copied from class: DefaultWatchThread

Registers a patch to watch.

Overrides:

registerPath in class DefaultWatchThread

Parameters:

dir - The directory to watch

Returns:

The watch key

Throws:

IOException - if an error occurs.

closeWatchService

protected void closeWatchService()

Description copied from class: DefaultWatchThread

Closes the watch service.

Overrides:

closeWatchService in class DefaultWatchThread