Catch exceptions in BaseCommandProcessor (#295)

Otherwise the StreamCommandProcessor stops at the unhandled exception and doesn't accept new commands.
OpenAS2 · Aug 30, 2022 · b042329 · b042329
1 parent db8e291
commit b042329
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/Server/src/main/java/org/openas2/cmd/processor/BaseCommandProcessor.java b/Server/src/main/java/org/openas2/cmd/processor/BaseCommandProcessor.java
@@ -14,6 +14,8 @@
 import java.util.Map;
 import java.util.concurrent.Callable;
 import java.util.concurrent.ScheduledExecutorService;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 
 public abstract class BaseCommandProcessor implements CommandProcessor, Component, HasSchedule {
@@ -89,7 +91,11 @@ public void schedule(ScheduledExecutorService executor) throws OpenAS2Exception
             @Override
             public Void call() throws Exception {
                 while (running) {
-                    processCommand();
+                    try {
+                        processCommand();
+                    } catch (Exception ex) {
+                        Logger.getLogger(BaseCommandProcessor.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
+                    }
                 }
                 return VOID;
             }