Not shutting down the new task executor after loading modules

Author: Rob Rudin

build.gradle

@@ -23,8 +23,8 @@ sourceCompatibility = "1.7"
 targetCompatibility = "1.7"
 
 repositories {
-  jcenter()
   mavenLocal() // Used for local development only
+  jcenter()
 }
 
 dependencies {

examples/local-testing-project/gradle.properties

@@ -1,6 +1,6 @@
 # Set this to the version you used when running
 # "gradle -Pversion=(something) publishToMavenLocal" on your local ml-gradle repo
-mlGradleVersion=DEV
+mlGradleVersion=2.6.DEV
 
 mlHost=localhost
 mlAppName=example

gradle.properties

@@ -1,5 +1,5 @@
 group=com.marklogic
-version=DEV
-mlAppDeployerDependency=com.marklogic:ml-app-deployer:DEV
+version=2.6.DEV
+mlAppDeployerDependency=com.marklogic:ml-app-deployer:2.6.DEV
 mlcpUtilDependency=com.marklogic:mlcp-util:0.3.0
 

src/main/groovy/com/marklogic/gradle/task/client/WatchTask.groovy

@@ -12,41 +12,43 @@ import com.marklogic.gradle.task.MarkLogicTask
 /**
  * Runs an infinite loop, and each second, it loads any new/modified modules. Often useful to run with the Gradle "-i" flag
  * so you can see which modules are loaded.
- * 
+ *
  * Depends on an instance of LoadModulesCommand being in the Gradle Project, which should have been placed there by
  * MarkLogicPlugin. This prevents this class from having to know how to construct a ModulesLoader.
  */
 class WatchTask extends MarkLogicTask {
 
-    long sleepTime = 1000
-
-    @TaskAction
-    public void watchModules() {
-        LoadModulesCommand command = getProject().property("mlLoadModulesCommand")
-        
-        // Adjust the loader to catch exceptions by default
-        ModulesLoader loader = command.getModulesLoader()
-        if (loader == null) {
-            command.initializeDefaultModulesLoader(getCommandContext())
-            loader = command.getModulesLoader()
-        }
-        if (loader instanceof DefaultModulesLoader) {
-            ((DefaultModulesLoader)loader).setCatchExceptions(true)
-        }
-        
-        List<String> paths = getAppConfig().getModulePaths()
-        println "Watching modules in paths: " + paths
-
-        DatabaseClient client = newClient()
-        while (true) {
-            for (String path : paths) {
-                loader.loadModules(new File(path), new DefaultModulesFinder(), client);
-            }
-            try {
-                Thread.sleep(sleepTime);
-            } catch (InterruptedException ie) {
-                // Ignore
-            }
-        }
-    }
+	long sleepTime = 1000
+
+	@TaskAction
+	void watchModules() {
+		LoadModulesCommand command = getProject().property("mlLoadModulesCommand")
+
+		ModulesLoader loader = command.getModulesLoader()
+		if (loader == null) {
+			command.initializeDefaultModulesLoader(getCommandContext())
+			loader = command.getModulesLoader()
+		}
+
+		if (loader instanceof DefaultModulesLoader) {
+			DefaultModulesLoader dml = (DefaultModulesLoader) loader;
+			dml.setCatchExceptions(true)
+			dml.setShutdownTaskExecutorAfterLoadingModules(false)
+		}
+
+		List<String> paths = getAppConfig().getModulePaths()
+		println "Watching modules in paths: " + paths
+
+		DatabaseClient client = newClient()
+		while (true) {
+			for (String path : paths) {
+				loader.loadModules(new File(path), new DefaultModulesFinder(), client);
+			}
+			try {
+				Thread.sleep(sleepTime);
+			} catch (InterruptedException ie) {
+				// Ignore
+			}
+		}
+	}
 }