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

removed duplicated method

parent 2d1da873
No related branches found
No related tags found
No related merge requests found
...@@ -19,8 +19,8 @@ package teetime.framework; ...@@ -19,8 +19,8 @@ package teetime.framework;
* Represents a minimal stage that composes several other stages. * Represents a minimal stage that composes several other stages.
* *
* @since 1.2 * @since 1.2
* @author Christian Wulf, Nelson Tavares de Sousa
* *
* @author Christian Wulf, Nelson Tavares de Sousa
* *
*/ */
public abstract class AbstractCompositeStage { public abstract class AbstractCompositeStage {
...@@ -50,11 +50,4 @@ public abstract class AbstractCompositeStage { ...@@ -50,11 +50,4 @@ public abstract class AbstractCompositeStage {
context.connectPorts(sourcePort, targetPort, capacity); context.connectPorts(sourcePort, targetPort, capacity);
} }
protected final <T> void connectBoundedInterThreads(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
ConfigurationContext.connectBoundedInterThreads(sourcePort, targetPort);
}
protected final <T> void connectBoundedInterThreads(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) {
ConfigurationContext.connectBoundedInterThreads(sourcePort, targetPort, capacity);
}
} }
...@@ -36,7 +36,7 @@ public class RunnableConsumerStageTestConfiguration extends Configuration { ...@@ -36,7 +36,7 @@ public class RunnableConsumerStageTestConfiguration extends Configuration {
addThreadableStage(collectorSink); addThreadableStage(collectorSink);
// Can not use createPorts, as the if condition above will lead to an exception // Can not use createPorts, as the if condition above will lead to an exception
connectBoundedInterThreads(producer.getOutputPort(), collectorSink.getInputPort()); ConfigurationContext.connectBoundedInterThreads(producer.getOutputPort(), collectorSink.getInputPort());
this.collectorSink = collectorSink; this.collectorSink = collectorSink;
} }
......
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