Close Vertx when there is an exception

Signed-off-by: Pierangelo Di Pilato <pierangelodipilato@gmail.com>
knative-extensions · Oct 23, 2020 · 8cc4e1f · 8cc4e1f
1 parent ff041f6
commit 8cc4e1f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/Main.java b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/Main.java
@@ -109,8 +109,9 @@ public static void main(final String[] args) {
 
       fw.watch(); // block forever
 
-    } catch (InterruptedException | IOException ex) {
+    } catch (final InterruptedException | IOException ex) {
       logger.error("failed during filesystem watch", ex);
+      vertx.close().onComplete(ignored -> System.exit(1));
     }
   }
 }
diff --git a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/Main.java b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/Main.java
@@ -121,8 +121,9 @@ public static void main(final String[] args) {
 
       fw.watch(); // block forever
 
-    } catch (InterruptedException | IOException ex) {
+    } catch (final InterruptedException | IOException ex) {
       logger.error("failed during filesystem watch", ex);
+      vertx.close().onComplete(ignored -> System.exit(1));
     }
   }
 }