From 448cdac5cfdd434e807a0b6659cc4bf0cd11d8dc Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Mon, 22 Sep 2014 15:37:22 +0200
Subject: [PATCH] removed capacity argument
---
.../examples/recordReader/RecordReaderConfiguration.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/test/java/teetime/variant/methodcallWithPorts/examples/recordReader/RecordReaderConfiguration.java b/src/test/java/teetime/variant/methodcallWithPorts/examples/recordReader/RecordReaderConfiguration.java
index 34af107b..485c0281 100644
--- a/src/test/java/teetime/variant/methodcallWithPorts/examples/recordReader/RecordReaderConfiguration.java
+++ b/src/test/java/teetime/variant/methodcallWithPorts/examples/recordReader/RecordReaderConfiguration.java
@@ -60,10 +60,10 @@ public class RecordReaderConfiguration extends Configuration {
// connect stages
this.pipeFactory.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false)
- .create(initialElementProducer.getOutputPort(), dir2RecordsFilter.getInputPort(), 1);
+ .create(initialElementProducer.getOutputPort(), dir2RecordsFilter.getInputPort());
this.pipeFactory.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false)
- .create(dir2RecordsFilter.getOutputPort(), collector.getInputPort(), 1);
+ .create(dir2RecordsFilter.getOutputPort(), collector.getInputPort());
return initialElementProducer;
}
--
GitLab