diff --git a/src/main/java/teetime/framework/AbstractRunnableStage.java b/src/main/java/teetime/framework/AbstractRunnableStage.java
index 3e496643b303d56b576f729922b516d7d8f91e93..8b20fa8c0c7f2490f674d8307ea4bbe5198f5780 100644
--- a/src/main/java/teetime/framework/AbstractRunnableStage.java
+++ b/src/main/java/teetime/framework/AbstractRunnableStage.java
@@ -4,13 +4,13 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import teetime.framework.exceptionHandling.StageException;
-import teetime.framework.exceptionHandling.StageExceptionHandler;
-import teetime.framework.exceptionHandling.StageExceptionHandler.FurtherExecution;
+import teetime.framework.exceptionHandling.AbstractStageExceptionHandler;
+import teetime.framework.exceptionHandling.AbstractStageExceptionHandler.FurtherExecution;
import teetime.framework.signal.TerminatingSignal;
abstract class AbstractRunnableStage implements Runnable {
- private final StageExceptionHandler exceptionHandler;
+ private final AbstractStageExceptionHandler exceptionHandler;
private static final String TERMINATING_THREAD_DUE_TO_THE_FOLLOWING_EXCEPTION = "Terminating thread due to the following exception: ";
@@ -18,7 +18,7 @@ abstract class AbstractRunnableStage implements Runnable {
@SuppressWarnings("PMD.LoggerIsNotStaticFinal")
protected final Logger logger;
- public AbstractRunnableStage(final Stage stage, final StageExceptionHandler exceptionHandler) {
+ public AbstractRunnableStage(final Stage stage, final AbstractStageExceptionHandler exceptionHandler) {
this.stage = stage;
this.logger = LoggerFactory.getLogger(stage.getClass());
this.exceptionHandler = exceptionHandler;
diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java
index ffb486638554a06248c22b7a2a4c6745b941e10e..9238dce94707318e07787c04ec8c59e0f812b0e2 100644
--- a/src/main/java/teetime/framework/Analysis.java
+++ b/src/main/java/teetime/framework/Analysis.java
@@ -25,7 +25,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import teetime.framework.exceptionHandling.IgnoringStageListener;
-import teetime.framework.exceptionHandling.StageExceptionHandler;
+import teetime.framework.exceptionHandling.AbstractStageExceptionHandler;
import teetime.framework.signal.ValidatingSignal;
import teetime.framework.validation.AnalysisNotValidException;
import teetime.util.Pair;
@@ -43,7 +43,7 @@ public final class Analysis implements UncaughtExceptionHandler {
private final AnalysisConfiguration configuration;
- private final Class<? extends teetime.framework.exceptionHandling.StageExceptionHandler> listener;
+ private final Class<? extends teetime.framework.exceptionHandling.AbstractStageExceptionHandler> listener;
private boolean executionInterrupted = false;
@@ -79,11 +79,11 @@ public final class Analysis implements UncaughtExceptionHandler {
* @param listener
* specific listener for the exception handling
*/
- public Analysis(final AnalysisConfiguration configuration, final Class<? extends StageExceptionHandler> listener) {
+ public Analysis(final AnalysisConfiguration configuration, final Class<? extends AbstractStageExceptionHandler> listener) {
this(configuration, false, listener);
}
- public Analysis(final AnalysisConfiguration configuration, final boolean validationEnabled, final Class<? extends StageExceptionHandler> listener) {
+ public Analysis(final AnalysisConfiguration configuration, final boolean validationEnabled, final Class<? extends AbstractStageExceptionHandler> listener) {
this.configuration = configuration;
this.listener = listener;
if (validationEnabled) {
@@ -124,7 +124,7 @@ public final class Analysis implements UncaughtExceptionHandler {
throw new IllegalStateException("No stage was added using the addThreadableStage(..) method. Add at least one stage.");
}
for (Stage stage : threadableStageJobs) {
- StageExceptionHandler newListener;
+ AbstractStageExceptionHandler newListener;
try {
newListener = listener.newInstance();
} catch (InstantiationException e) {
diff --git a/src/main/java/teetime/framework/RunnableConsumerStage.java b/src/main/java/teetime/framework/RunnableConsumerStage.java
index 9f7ac0c88521dabf21fcbccf2dd5503149d74652..9c37dde762205d47ddc91c151924c23181d99d42 100644
--- a/src/main/java/teetime/framework/RunnableConsumerStage.java
+++ b/src/main/java/teetime/framework/RunnableConsumerStage.java
@@ -15,7 +15,7 @@
*/
package teetime.framework;
-import teetime.framework.exceptionHandling.StageExceptionHandler;
+import teetime.framework.exceptionHandling.AbstractStageExceptionHandler;
import teetime.framework.idle.IdleStrategy;
import teetime.framework.idle.YieldStrategy;
import teetime.framework.signal.ISignal;
@@ -32,11 +32,11 @@ final class RunnableConsumerStage extends AbstractRunnableStage {
* @param stage
* to execute within an own thread
*/
- public RunnableConsumerStage(final Stage stage, final StageExceptionHandler exceptionListener) {
+ public RunnableConsumerStage(final Stage stage, final AbstractStageExceptionHandler exceptionListener) {
this(stage, new YieldStrategy(), exceptionListener);
}
- public RunnableConsumerStage(final Stage stage, final IdleStrategy idleStrategy, final StageExceptionHandler exceptionListener) {
+ public RunnableConsumerStage(final Stage stage, final IdleStrategy idleStrategy, final AbstractStageExceptionHandler exceptionListener) {
super(stage, exceptionListener);
this.inputPorts = stage.getInputPorts(); // FIXME should getInputPorts() really be defined in Stage?
}
diff --git a/src/main/java/teetime/framework/RunnableProducerStage.java b/src/main/java/teetime/framework/RunnableProducerStage.java
index 8feebfebc303c3f06d2e804ff3bed4a7356ae4c3..fc4c8a546bd17a7f08678da4001697dfe741661d 100644
--- a/src/main/java/teetime/framework/RunnableProducerStage.java
+++ b/src/main/java/teetime/framework/RunnableProducerStage.java
@@ -15,13 +15,13 @@
*/
package teetime.framework;
-import teetime.framework.exceptionHandling.StageExceptionHandler;
+import teetime.framework.exceptionHandling.AbstractStageExceptionHandler;
import teetime.framework.signal.StartingSignal;
import teetime.framework.signal.TerminatingSignal;
public final class RunnableProducerStage extends AbstractRunnableStage {
- public RunnableProducerStage(final Stage stage, final StageExceptionHandler listener) {
+ public RunnableProducerStage(final Stage stage, final AbstractStageExceptionHandler listener) {
super(stage, listener);
}
diff --git a/src/main/java/teetime/framework/exceptionHandling/StageExceptionHandler.java b/src/main/java/teetime/framework/exceptionHandling/AbstractStageExceptionHandler.java
similarity index 91%
rename from src/main/java/teetime/framework/exceptionHandling/StageExceptionHandler.java
rename to src/main/java/teetime/framework/exceptionHandling/AbstractStageExceptionHandler.java
index c413fd2d995d5ec05ae48d492f18f370df30078f..eac052e88179d138f05c61cfc3b3008f2a84b676 100644
--- a/src/main/java/teetime/framework/exceptionHandling/StageExceptionHandler.java
+++ b/src/main/java/teetime/framework/exceptionHandling/AbstractStageExceptionHandler.java
@@ -9,7 +9,7 @@ import teetime.framework.Stage;
* Represent a minimalistic StageExceptionListener. Listener which extend from this one, must a least implement this functionality.
* This abstract class provides a Logger {@link #logger} and a method to terminate the threads execution {@link #terminateExecution()}.
*/
-public abstract class StageExceptionHandler {
+public abstract class AbstractStageExceptionHandler {
public enum FurtherExecution {
CONTINUE, TERMINATE
@@ -20,7 +20,7 @@ public abstract class StageExceptionHandler {
*/
protected final Logger logger;
- public StageExceptionHandler() {
+ public AbstractStageExceptionHandler() {
this.logger = LoggerFactory.getLogger(this.getClass().getCanonicalName());
}
diff --git a/src/main/java/teetime/framework/exceptionHandling/IgnoringStageListener.java b/src/main/java/teetime/framework/exceptionHandling/IgnoringStageListener.java
index 0a169c8c5d9c9114ff79ebf6edcd1f547a7985de..a815fa2a27b29db549c7af746eb7ada2814cbc6d 100644
--- a/src/main/java/teetime/framework/exceptionHandling/IgnoringStageListener.java
+++ b/src/main/java/teetime/framework/exceptionHandling/IgnoringStageListener.java
@@ -2,7 +2,7 @@ package teetime.framework.exceptionHandling;
import teetime.framework.Stage;
-public class IgnoringStageListener extends StageExceptionHandler {
+public class IgnoringStageListener extends AbstractStageExceptionHandler {
public IgnoringStageListener() {
super();
diff --git a/src/main/java/teetime/framework/exceptionHandling/LoggingStageListener.java b/src/main/java/teetime/framework/exceptionHandling/LoggingStageListener.java
index 4341620cb83c1d6c8a5ff0e5108ba7a8a9a4fe37..8df9fc4517d9b3634f61e48622052ecb7320cbd5 100644
--- a/src/main/java/teetime/framework/exceptionHandling/LoggingStageListener.java
+++ b/src/main/java/teetime/framework/exceptionHandling/LoggingStageListener.java
@@ -2,7 +2,7 @@ package teetime.framework.exceptionHandling;
import teetime.framework.Stage;
-public class LoggingStageListener extends StageExceptionHandler {
+public class LoggingStageListener extends AbstractStageExceptionHandler {
@Override
public FurtherExecution onStageException(final Exception e, final Stage throwingStage) {
diff --git a/src/main/java/teetime/framework/exceptionHandling/TerminatingStageListener.java b/src/main/java/teetime/framework/exceptionHandling/TerminatingStageListener.java
index 74711a0aa3d981cc6baad27593237ff1062f9fb2..020e7fbe733b9b0b392f6ce0150bb82d40b10450 100644
--- a/src/main/java/teetime/framework/exceptionHandling/TerminatingStageListener.java
+++ b/src/main/java/teetime/framework/exceptionHandling/TerminatingStageListener.java
@@ -2,7 +2,7 @@ package teetime.framework.exceptionHandling;
import teetime.framework.Stage;
-public class TerminatingStageListener extends StageExceptionHandler {
+public class TerminatingStageListener extends AbstractStageExceptionHandler {
@Override
public FurtherExecution onStageException(final Exception e, final Stage throwingStage) {
diff --git a/src/site/markdown/wiki b/src/site/markdown/wiki
index 63ccbbc87bd2c0e6599ca91502149dba3cfb99de..162510ff4d2f04011498ba6920aae0c78347c6c8 160000
--- a/src/site/markdown/wiki
+++ b/src/site/markdown/wiki
@@ -1 +1 @@
-Subproject commit 63ccbbc87bd2c0e6599ca91502149dba3cfb99de
+Subproject commit 162510ff4d2f04011498ba6920aae0c78347c6c8
diff --git a/src/test/java/teetime/framework/exceptionHandling/TestListener.java b/src/test/java/teetime/framework/exceptionHandling/TestListener.java
index cf1016825465825b7072d5812375b66c397916b3..809fbd5f727048a9da3583c9bc4830a26c8b2b79 100644
--- a/src/test/java/teetime/framework/exceptionHandling/TestListener.java
+++ b/src/test/java/teetime/framework/exceptionHandling/TestListener.java
@@ -2,7 +2,7 @@ package teetime.framework.exceptionHandling;
import teetime.framework.Stage;
-public class TestListener extends StageExceptionHandler {
+public class TestListener extends AbstractStageExceptionHandler {
public static int exceptionInvoked = 0;