diff --git a/runtime/command-start/src/main/java/io/aklivity/zilla/runtime/command/start/internal/airline/ZillaStartCommand.java b/runtime/command-start/src/main/java/io/aklivity/zilla/runtime/command/start/internal/airline/ZillaStartCommand.java index 79d462a608..3c10924e43 100644 --- a/runtime/command-start/src/main/java/io/aklivity/zilla/runtime/command/start/internal/airline/ZillaStartCommand.java +++ b/runtime/command-start/src/main/java/io/aklivity/zilla/runtime/command/start/internal/airline/ZillaStartCommand.java @@ -32,6 +32,7 @@ import java.util.List; import java.util.Properties; import java.util.concurrent.CountDownLatch; +import java.util.function.Consumer; import org.agrona.ErrorHandler; @@ -147,10 +148,8 @@ public void run() } } - final ErrorHandler onError = ex -> - { - stop.countDown(); - }; + final ErrorHandler onError = ex -> stop.countDown(); + final Consumer errorReporter = config.errorReporter(); try (Engine engine = Engine.builder() .config(config) @@ -171,8 +170,7 @@ public void run() } catch (Throwable ex) { - System.out.println("error"); - onError.onError(ex); + errorReporter.accept(ex); rethrowUnchecked(ex); } } diff --git a/runtime/command/src/main/java/io/aklivity/zilla/runtime/command/internal/ZillaMain.java b/runtime/command/src/main/java/io/aklivity/zilla/runtime/command/internal/ZillaMain.java index 7d8a9c87fe..85e0a34195 100644 --- a/runtime/command/src/main/java/io/aklivity/zilla/runtime/command/internal/ZillaMain.java +++ b/runtime/command/src/main/java/io/aklivity/zilla/runtime/command/internal/ZillaMain.java @@ -70,7 +70,6 @@ private static int invoke( } catch (Throwable ex) { - // TODO: debug output status = 1; }