0005235: Restarting engine from failed engine dialog not working

JumpMind · Mar 3, 2022 · 9185634 · 9185634
1 parent 7072a8b
commit 9185634
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymmetricEngineHolder.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymmetricEngineHolder.java
@@ -160,12 +160,22 @@ public void start() {
     public synchronized void restart(String engineName) {
         FailedEngineInfo info = enginesFailed.get(engineName);
         if (info != null) {
+            ISymmetricEngine engine = engines.get(engineName);
+            if (engine != null) {
+                try {
+                    engine.destroy();
+                } catch (Exception e) {
+                    log.warn("Destroy of engine failed", e);
+                }
+                engines.remove(engineName);
+            }
             enginesFailed.remove(engineName);
             if (restartExecutor == null) {
                 int poolSize = Integer.parseInt(System.getProperty(SystemConstants.SYSPROP_CONCURRENT_ENGINES_STARTING_COUNT, "5"));
                 restartExecutor = Executors.newFixedThreadPool(poolSize, new CustomizableThreadFactory("symmetric-engine-restart"));
             }
             SymmetricEngineStarter starter = new SymmetricEngineStarter(info.getPropertyFileName(), this);
+            enginesStarting.add(starter);
             restartExecutor.execute(starter);
         }
     }