Add uncaught exception handler to barrage-example mains (#4619)

Related to #4618
deephaven · Oct 10, 2023 · e12d8cb · e12d8cb
1 parent c6a1f8c
commit e12d8cb
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/java-client/barrage-examples/src/main/java/io/deephaven/client/examples/SnapshotTable.java b/java-client/barrage-examples/src/main/java/io/deephaven/client/examples/SnapshotTable.java
@@ -3,6 +3,7 @@
  */
 package io.deephaven.client.examples;
 
+import io.deephaven.base.system.AsyncSystem;
 import io.deephaven.qst.TableCreationLogic;
 import picocli.CommandLine;
 import picocli.CommandLine.ArgGroup;
@@ -21,6 +22,7 @@ protected TableCreationLogic logic() {
     }
 
     public static void main(String[] args) {
+        Thread.setDefaultUncaughtExceptionHandler(AsyncSystem.uncaughtExceptionHandler(1, System.err));
         int execute = new CommandLine(new SnapshotTable()).execute(args);
         System.exit(execute);
     }

diff --git a/java-client/barrage-examples/src/main/java/io/deephaven/client/examples/SubscribeQST.java b/java-client/barrage-examples/src/main/java/io/deephaven/client/examples/SubscribeQST.java
@@ -3,6 +3,7 @@
  */
 package io.deephaven.client.examples;
 
+import io.deephaven.base.system.AsyncSystem;
 import io.deephaven.qst.TableCreationLogic;
 import io.deephaven.qst.table.TableSpec;
 import io.deephaven.qst.table.TimeTable;
@@ -23,6 +24,7 @@ protected TableCreationLogic logic() {
     }
 
     public static void main(String[] args) {
+        Thread.setDefaultUncaughtExceptionHandler(AsyncSystem.uncaughtExceptionHandler(1, System.err));
         int execute = new CommandLine(new SubscribeQST()).execute(args);
         System.exit(execute);
     }

diff --git a/java-client/barrage-examples/src/main/java/io/deephaven/client/examples/SubscribeTable.java b/java-client/barrage-examples/src/main/java/io/deephaven/client/examples/SubscribeTable.java
@@ -3,6 +3,7 @@
  */
 package io.deephaven.client.examples;
 
+import io.deephaven.base.system.AsyncSystem;
 import io.deephaven.qst.TableCreationLogic;
 import picocli.CommandLine;
 import picocli.CommandLine.ArgGroup;
@@ -21,6 +22,7 @@ protected TableCreationLogic logic() {
     }
 
     public static void main(String[] args) {
+        Thread.setDefaultUncaughtExceptionHandler(AsyncSystem.uncaughtExceptionHandler(1, System.err));
         int execute = new CommandLine(new SubscribeTable()).execute(args);
         System.exit(execute);
     }