renamed method

src/main/java/teetime/framework/AnalysisConfiguration.java

@@ -145,7 +145,7 @@ public abstract class AnalysisConfiguration {
 		return interUnboundedThreadFactory.create(sourcePort, targetPort, capacity);
 	}
 
-	protected <T> void connectStages(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
+	protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
 		connections.add(new Pair<OutputPort, InputPort>(sourcePort, targetPort));
 	}
 

src/main/java/teetime/framework/test/StageTester.java

@@ -88,7 +88,7 @@ public final class StageTester {
 		public Configuration(final List<InputHolder<?>> inputHolders, final Stage stage, final List<OutputHolder<?>> outputHolders) {
 			for (InputHolder<?> inputHolder : inputHolders) {
 				final InitialElementProducer<Object> producer = new InitialElementProducer<Object>(inputHolder.getInput());
-				connectStages(producer.getOutputPort(), inputHolder.getPort());
+				connectPorts(producer.getOutputPort(), inputHolder.getPort());
 				addThreadableStage(producer);
 			}
 
@@ -96,7 +96,7 @@ public final class StageTester {
 
 			for (OutputHolder<?> outputHolder : outputHolders) {
 				final CollectorSink<Object> sink = new CollectorSink<Object>(outputHolder.getOutputElements());
-				connectStages(outputHolder.getPort(), sink.getInputPort());
+				connectPorts(outputHolder.getPort(), sink.getInputPort());
 			}
 		}
 	}

src/test/java/teetime/examples/cipher/CipherConfiguration.java

@@ -40,12 +40,12 @@ public class CipherConfiguration extends AnalysisConfiguration {
 		final CipherStage decrypt = new CipherStage(password, CipherMode.DECRYPT);
 		final ByteArrayFileWriter writer = new ByteArrayFileWriter(output);
 
-		connectStages(init.getOutputPort(), f2b.getInputPort());
-		connectStages(f2b.getOutputPort(), enc.getInputPort());
-		connectStages(enc.getOutputPort(), comp.getInputPort());
-		connectStages(comp.getOutputPort(), decomp.getInputPort());
-		connectStages(decomp.getOutputPort(), decrypt.getInputPort());
-		connectStages(decrypt.getOutputPort(), writer.getInputPort());
+		connectPorts(init.getOutputPort(), f2b.getInputPort());
+		connectPorts(f2b.getOutputPort(), enc.getInputPort());
+		connectPorts(enc.getOutputPort(), comp.getInputPort());
+		connectPorts(comp.getOutputPort(), decomp.getInputPort());
+		connectPorts(decomp.getOutputPort(), decrypt.getInputPort());
+		connectPorts(decrypt.getOutputPort(), writer.getInputPort());
 
 		// this.getFiniteProducerStages().add(init);
 		this.addThreadableStage(init);

src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java

@@ -43,12 +43,12 @@ public class TokenizerConfiguration extends AnalysisConfiguration {
 		final Tokenizer tokenizer = new Tokenizer(" ");
 		this.counter = new Counter<String>();
 
-		connectStages(init.getOutputPort(), f2b.getInputPort());
-		connectStages(f2b.getOutputPort(), decomp.getInputPort());
-		connectStages(decomp.getOutputPort(), decrypt.getInputPort());
-		connectStages(decrypt.getOutputPort(), b2s.getInputPort());
-		connectStages(b2s.getOutputPort(), tokenizer.getInputPort());
-		connectStages(tokenizer.getOutputPort(), this.counter.getInputPort());
+		connectPorts(init.getOutputPort(), f2b.getInputPort());
+		connectPorts(f2b.getOutputPort(), decomp.getInputPort());
+		connectPorts(decomp.getOutputPort(), decrypt.getInputPort());
+		connectPorts(decrypt.getOutputPort(), b2s.getInputPort());
+		connectPorts(b2s.getOutputPort(), tokenizer.getInputPort());
+		connectPorts(tokenizer.getOutputPort(), this.counter.getInputPort());
 
 		this.addThreadableStage(init);
 	}

src/test/java/teetime/framework/AnalysisTest.java

@@ -73,7 +73,7 @@ public class AnalysisTest {
 		public TestConfig() {
 			final InitialElementProducer<String> init = new InitialElementProducer<String>("Hello");
 			delay = new DelayAndTerminate(DELAY_IN_MS);
-			connectStages(init.getOutputPort(), delay.getInputPort());
+			connectPorts(init.getOutputPort(), delay.getInputPort());
 			addThreadableStage(init);
 		}
 	}
@@ -114,7 +114,7 @@ public class AnalysisTest {
 		public Sink<Object> sink = new Sink<Object>();
 
 		public AnalysisTestConfig(final boolean inter) {
-			connectStages(init.getOutputPort(), sink.getInputPort());
+			connectPorts(init.getOutputPort(), sink.getInputPort());
 			addThreadableStage(init);
 			if (inter) {
 				addThreadableStage(sink);

src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java

@@ -35,7 +35,7 @@ public class RunnableConsumerStageTestConfiguration extends AnalysisConfiguratio
 		CollectorSink<Integer> collectorSink = new CollectorSink<Integer>(collectedElements);
 		addThreadableStage(collectorSink);
 
-		connectStages(producer.getOutputPort(), collectorSink.getInputPort());
+		connectPorts(producer.getOutputPort(), collectorSink.getInputPort());
 
 		this.collectorSink = collectorSink;
 	}

src/test/java/teetime/framework/StageTest.java

@@ -60,7 +60,7 @@ public class StageTest {
 		public TestConfig() {
 			init = new InitialElementProducer<String>("Hello");
 			delay = new DelayAndTerminate(0);
-			connectStages(init.getOutputPort(), delay.getInputPort());
+			connectPorts(init.getOutputPort(), delay.getInputPort());
 			addThreadableStage(init);
 		}
 	}

src/test/java/teetime/framework/TraversorTest.java

@@ -71,8 +71,8 @@ public class TraversorTest {
 			// CountingMapMerger (already as field)
 
 			// Connecting the stages of the first part of the config
-			connectStages(init.getOutputPort(), f2b.getInputPort());
-			connectStages(f2b.getOutputPort(), distributor.getInputPort());
+			connectPorts(init.getOutputPort(), f2b.getInputPort());
+			connectPorts(f2b.getOutputPort(), distributor.getInputPort());
 
 			// Middle part... multiple instances of WordCounter are created and connected to the merger and distrubuter stages
 			for (int i = 0; i < threads; i++) {
@@ -80,15 +80,15 @@ public class TraversorTest {
 				final WordCounter wc = new WordCounter();
 				// intraFact.create(inputPortSizePrinter.getOutputPort(), wc.getInputPort());
 
-				connectStages(distributor.getNewOutputPort(), wc.getInputPort());
-				connectStages(wc.getOutputPort(), merger.getNewInputPort());
+				connectPorts(distributor.getNewOutputPort(), wc.getInputPort());
+				connectPorts(wc.getOutputPort(), merger.getNewInputPort());
 				// Add WordCounter as a threadable stage, so it runs in its own thread
 				addThreadableStage(wc);
 
 			}
 
 			// Connect the stages of the last part
-			connectStages(merger.getOutputPort(), result.getInputPort());
+			connectPorts(merger.getOutputPort(), result.getInputPort());
 
 			// Add the first and last part to the threadable stages
 			addThreadableStage(init);

src/test/java/teetime/framework/WaitStrategyConfiguration.java

@@ -42,7 +42,7 @@ class WaitStrategyConfiguration extends AnalysisConfiguration {
 		Clock clock = new Clock();
 		clock.setInitialDelayInMs(initialDelayInMs);
 
-		connectStages(clock.getOutputPort(), delay.getTimestampTriggerInputPort());
+		connectPorts(clock.getOutputPort(), delay.getTimestampTriggerInputPort());
 
 		return clock;
 	}
@@ -51,7 +51,7 @@ class WaitStrategyConfiguration extends AnalysisConfiguration {
 		InitialElementProducer<Object> initialElementProducer = new InitialElementProducer<Object>(elements);
 		delay = new Delay<Object>();
 
-		connectStages(initialElementProducer.getOutputPort(), delay.getInputPort());
+		connectPorts(initialElementProducer.getOutputPort(), delay.getInputPort());
 
 		return initialElementProducer;
 	}
@@ -62,8 +62,8 @@ class WaitStrategyConfiguration extends AnalysisConfiguration {
 
 		// relay.setIdleStrategy(new WaitStrategy(relay));
 
-		connectStages(delay.getOutputPort(), relay.getInputPort());
-		connectStages(relay.getOutputPort(), collectorSink.getInputPort());
+		connectPorts(delay.getOutputPort(), relay.getInputPort());
+		connectPorts(relay.getOutputPort(), collectorSink.getInputPort());
 
 		this.collectorSink = collectorSink;
 

src/test/java/teetime/framework/YieldStrategyConfiguration.java

@@ -44,8 +44,8 @@ class YieldStrategyConfiguration extends AnalysisConfiguration {
 
 		// relay.setIdleStrategy(new YieldStrategy());
 
-		connectStages(producer.getOutputPort(), relay.getInputPort());
-		connectStages(relay.getOutputPort(), collectorSink.getInputPort());
+		connectPorts(producer.getOutputPort(), relay.getInputPort());
+		connectPorts(relay.getOutputPort(), collectorSink.getInputPort());
 
 		this.collectorSink = collectorSink;
 

src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java

@@ -28,7 +28,7 @@ public class ExceptionTestConfiguration extends AnalysisConfiguration {
 		second = new ExceptionTestConsumerStage();
 		third = new ExceptionTestProducerStage();
 
-		connectStages(first.getOutputPort(), second.getInputPort());
+		connectPorts(first.getOutputPort(), second.getInputPort());
 		// this.addThreadableStage(new ExceptionTestStage());
 
 		this.addThreadableStage(first);

src/test/java/teetime/stage/InstanceOfFilterTest.java

@@ -130,9 +130,9 @@ public class InstanceOfFilterTest {
 			CollectorSink<Clazz> clazzCollector = new CollectorSink<Clazz>();
 			CollectorSink<Object> mismatchedCollector = new CollectorSink<Object>();
 
-			connectStages(elementProducer.getOutputPort(), instanceOfFilter.getInputPort());
-			connectStages(instanceOfFilter.getMatchedOutputPort(), clazzCollector.getInputPort());
-			connectStages(instanceOfFilter.getMismatchedOutputPort(), mismatchedCollector.getInputPort());
+			connectPorts(elementProducer.getOutputPort(), instanceOfFilter.getInputPort());
+			connectPorts(instanceOfFilter.getMatchedOutputPort(), clazzCollector.getInputPort());
+			connectPorts(instanceOfFilter.getMismatchedOutputPort(), mismatchedCollector.getInputPort());
 
 			addThreadableStage(elementProducer);
 		}