From d655afa6087797bdea94de10f6f4b11b8e4e526d Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Thu, 6 Aug 2015 15:07:58 +0200
Subject: [PATCH] added abort to TerminatingSignal
---
src/main/java/teetime/framework/signal/TerminatingSignal.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/src/main/java/teetime/framework/signal/TerminatingSignal.java b/src/main/java/teetime/framework/signal/TerminatingSignal.java
index 32ec5bf2..96ef9d3b 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);
}
}
--
GitLab