diff --git a/src/main/java/teetime/framework/ConfigurationContext.java b/src/main/java/teetime/framework/ConfigurationContext.java index f1cdf0381f41e026b616fdea38eafb7d07a98577..ed4c355e2286d3a134ddc4c7bb998502058a7dd7 100644 --- a/src/main/java/teetime/framework/ConfigurationContext.java +++ b/src/main/java/teetime/framework/ConfigurationContext.java @@ -47,7 +47,7 @@ public final class ConfigurationContext { * @param stage * A arbitrary stage, which will be added to the configuration and executed in a thread. */ - protected final void addThreadableStage(final Stage stage) { + final void addThreadableStage(final Stage stage) { if (!this.threadableStages.add(stage)) { LOGGER.warn("Stage " + stage.getId() + " was already marked as threadable stage."); } @@ -63,7 +63,7 @@ public final class ConfigurationContext { * @param <T> * the type of elements to be sent */ - protected final <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { + final <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { connectPorts(sourcePort, targetPort, 4); } @@ -79,7 +79,7 @@ public final class ConfigurationContext { * @param <T> * the type of elements to be sent */ - protected final <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) { + final <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) { if (sourcePort.getOwningStage().getInputPorts().length == 0 && !threadableStages.contains(sourcePort.getOwningStage())) { addThreadableStage(sourcePort.getOwningStage()); }