diff --git a/src/main/java/teetime/framework/signal/TerminatingSignal.java b/src/main/java/teetime/framework/signal/TerminatingSignal.java index 32ec5bf20e9d38a56c0f949d32954cae4490be52..96ef9d3be7b05512cc2a521ba4c9213ede16abbc 100644 --- a/src/main/java/teetime/framework/signal/TerminatingSignal.java +++ b/src/main/java/teetime/framework/signal/TerminatingSignal.java @@ -19,6 +19,7 @@ import java.util.List; import java.util.Set; import teetime.framework.InputPort; +import teetime.framework.RuntimeServiceFacade; import teetime.framework.Stage; public final class TerminatingSignal extends AbstractSignal { @@ -29,6 +30,7 @@ public final class TerminatingSignal extends AbstractSignal { stage.onTerminating(); } catch (final Exception e) { // NOCS NOPMD (Stages can throw any arbitrary Exception) this.catchedExceptions.add(e); + RuntimeServiceFacade.INSTANCE.abortExecution(stage); LOGGER.error("Exception while sending the termination signal", e); } }