From e714a5a876322a163d6245574e3b7f168dbf5c73 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Tue, 23 Jun 2015 10:56:30 +0200
Subject: [PATCH] removed duplicated method
---
.../java/teetime/framework/AbstractCompositeStage.java | 9 +--------
.../RunnableConsumerStageTestConfiguration.java | 2 +-
2 files changed, 2 insertions(+), 9 deletions(-)
diff --git a/src/main/java/teetime/framework/AbstractCompositeStage.java b/src/main/java/teetime/framework/AbstractCompositeStage.java
index 1a7fd869..984ca181 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 965fe3e6..c2305835 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;
}
--
GitLab