Skip to content
Snippets Groups Projects
Commit 91629b5b authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

set methods to package private

parent 05950708
No related branches found
No related tags found
No related merge requests found
...@@ -47,7 +47,7 @@ public final class ConfigurationContext { ...@@ -47,7 +47,7 @@ public final class ConfigurationContext {
* @param stage * @param stage
* A arbitrary stage, which will be added to the configuration and executed in a thread. * 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)) { if (!this.threadableStages.add(stage)) {
LOGGER.warn("Stage " + stage.getId() + " was already marked as threadable stage."); LOGGER.warn("Stage " + stage.getId() + " was already marked as threadable stage.");
} }
...@@ -63,7 +63,7 @@ public final class ConfigurationContext { ...@@ -63,7 +63,7 @@ public final class ConfigurationContext {
* @param <T> * @param <T>
* the type of elements to be sent * 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); connectPorts(sourcePort, targetPort, 4);
} }
...@@ -79,7 +79,7 @@ public final class ConfigurationContext { ...@@ -79,7 +79,7 @@ public final class ConfigurationContext {
* @param <T> * @param <T>
* the type of elements to be sent * 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())) { if (sourcePort.getOwningStage().getInputPorts().length == 0 && !threadableStages.contains(sourcePort.getOwningStage())) {
addThreadableStage(sourcePort.getOwningStage()); addThreadableStage(sourcePort.getOwningStage());
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment