Commit 6440909c authored by Christian Wulf's avatar Christian Wulf

changed onTerminating() from public to protected

parent 102a0b01
...@@ -430,7 +430,7 @@ public abstract class AbstractStage { ...@@ -430,7 +430,7 @@ public abstract class AbstractStage {
* *
* <pre> * <pre>
* &#64;Override * &#64;Override
* public void onStarting() { * protected void onStarting() {
* super.onStarting(); * super.onStarting();
* // insert your code here * // insert your code here
* } * }
...@@ -457,7 +457,7 @@ public abstract class AbstractStage { ...@@ -457,7 +457,7 @@ public abstract class AbstractStage {
* *
* <pre> * <pre>
* &#64;Override * &#64;Override
* public void onTerminating() { * protected void onTerminating() {
* // insert your code here * // insert your code here
* super.onTerminating(); * super.onTerminating();
* } * }
...@@ -466,7 +466,7 @@ public abstract class AbstractStage { ...@@ -466,7 +466,7 @@ public abstract class AbstractStage {
* To throw a checked exception, wrap it to an unchecked exception, e.g. to an {@link IllegalArgumentException#IllegalArgumentException(String, Throwable)}. * To throw a checked exception, wrap it to an unchecked exception, e.g. to an {@link IllegalArgumentException#IllegalArgumentException(String, Throwable)}.
* Always pass the original exception to the new unchecked exception to allow easy debugging. * Always pass the original exception to the new unchecked exception to allow easy debugging.
*/ */
public void onTerminating() { protected void onTerminating() {
logger.trace(ON_STATE_CHANGE_MARKER, "Terminating {}", this); logger.trace(ON_STATE_CHANGE_MARKER, "Terminating {}", this);
if (newStateRequired(StageActivationState.TERMINATED)) { if (newStateRequired(StageActivationState.TERMINATED)) {
this.addState(StageActivationState.TERMINATED, System.nanoTime()); this.addState(StageActivationState.TERMINATED, System.nanoTime());
......
...@@ -114,4 +114,8 @@ public final class StageFacade { ...@@ -114,4 +114,8 @@ public final class StageFacade {
stage.onStarting(); stage.onStarting();
} }
public void onTerminating(final AbstractStage stage) {
stage.onTerminating();
}
} }
...@@ -20,12 +20,13 @@ import java.util.Set; ...@@ -20,12 +20,13 @@ import java.util.Set;
import teetime.framework.AbstractStage; import teetime.framework.AbstractStage;
import teetime.framework.InputPort; import teetime.framework.InputPort;
import teetime.framework.StageFacade;
public final class TerminatingSignal implements ISignal { public final class TerminatingSignal implements ISignal {
@Override @Override
public void trigger(final AbstractStage stage) { public void trigger(final AbstractStage stage) {
stage.onTerminating(); StageFacade.INSTANCE.onTerminating(stage);
} }
@Override @Override
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment