diff --git a/src/main/java/teetime/framework/AbstractCompositeStage.java b/src/main/java/teetime/framework/AbstractCompositeStage.java index 1a7fd8696a5062b259c19246ef62d331363d7771..984ca18157bcdeab7809b13c0eeee41d7ddeaee8 100644 --- a/src/main/java/teetime/framework/AbstractCompositeStage.java +++ b/src/main/java/teetime/framework/AbstractCompositeStage.java @@ -19,8 +19,8 @@ package teetime.framework; * Represents a minimal stage that composes several other stages. * * @since 1.2 - * @author Christian Wulf, Nelson Tavares de Sousa * + * @author Christian Wulf, Nelson Tavares de Sousa * */ public abstract class AbstractCompositeStage { @@ -50,11 +50,4 @@ public abstract class AbstractCompositeStage { 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); - } } diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java index 965fe3e609807173084ef1e77b942b5458ce27f1..c2305835696076d0e4c6bfead0676536e35bc34f 100644 --- a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java +++ b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java @@ -36,7 +36,7 @@ public class RunnableConsumerStageTestConfiguration extends Configuration { addThreadableStage(collectorSink); // 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; }