Package 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(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	Description
MacOsWatchThread(ApplicationEventPublisher eventPublisher, FileWatchConfiguration configuration, WatchService watchService)	Default constructor.

Method Summary

Modifier and Type	Method	Description
protected void	closeWatchService()	Closes the watch service.
protected @NonNull WatchKey	registerPath(@NonNull 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 Details

MacOsWatchThread

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

Default constructor.

Parameters:

eventPublisher - The event publisher

configuration - the configuration

watchService - the watch service

Method Details

registerPath

@NonNull
protected @NonNull WatchKey registerPath(@NonNull
 @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