v3 31

2024-07-20 01:23:26 +02:00 · 2024-07-20 01:23:26 +02:00 · 861dcd00d8
commit 861dcd00d8
parent 0aee64c7f3
1 changed files with 6 additions and 4 deletions
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/watcher/InputDirectoryWatcher.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/watcher/InputDirectoryWatcher.kt
@ -74,10 +74,12 @@ class InputDirectoryWatcher(@Autowired var coordinator: Coordinator): FileWatche
                e.printStackTrace()
            }
        }
-        log.warn { "Watcher stopped!!!" }
-        if (!isStopping) {
-            ioCoroutine.launch {
-                watchFiles()
+        watcherChannel.invokeOnClose {
+            log.warn { "Watcher stopped!!!" }
+            if (!isStopping) {
+                ioCoroutine.launch {
+                    watchFiles()
+                }
            }
        }
    }