renamed setSignal to sendSignal

src/main/java/teetime/framework/OutputPort.java

@@ -18,7 +18,7 @@ public final class OutputPort<T> extends AbstractPort<T> {
 	}
 
 	public void sendSignal(final ISignal signal) {
-		this.pipe.setSignal(signal);
+		this.pipe.sendSignal(signal);
 	}
 
 	public void reportNewElement() {

src/main/java/teetime/framework/pipe/DummyPipe.java

@@ -44,7 +44,7 @@ public final class DummyPipe implements IPipe {
 	}
 
 	@Override
-	public void setSignal(final ISignal signal) {}
+	public void sendSignal(final ISignal signal) {}
 
 	@Override
 	public void connectPorts(final OutputPort sourcePort, final InputPort targetPort) {}

src/main/java/teetime/framework/pipe/IPipe.java

@@ -18,7 +18,7 @@ public interface IPipe {
 
 	InputPort<?> getTargetPort();
 
-	void setSignal(ISignal signal);
+	void sendSignal(ISignal signal);
 
 	@Deprecated
 	<T> void connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort);

src/main/java/teetime/framework/pipe/InterThreadPipe.java

@@ -13,14 +13,14 @@ import teetime.framework.signal.ISignal;
 
 public abstract class InterThreadPipe extends AbstractPipe {
 
-	private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT));;
+	private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT));
 
 	<T> InterThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
 		super(sourcePort, targetPort);
 	}
 
 	@Override
-	public void setSignal(final ISignal signal) {
+	public void sendSignal(final ISignal signal) {
 		this.signalQueue.offer(signal);
 	}
 

src/main/java/teetime/framework/pipe/IntraThreadPipe.java

@@ -11,7 +11,7 @@ public abstract class IntraThreadPipe extends AbstractPipe {
 	}
 
 	@Override
-	public void setSignal(final ISignal signal) {
+	public void sendSignal(final ISignal signal) {
 		if (this.getTargetPort() != null) { // BETTER remove this check since there are DummyPorts
 			this.cachedTargetStage.onSignal(signal, this.getTargetPort());
 		}

src/performancetest/java/teetime/examples/experiment17/MethodCallThroughputAnalysis17.java

@@ -149,7 +149,7 @@ public class MethodCallThroughputAnalysis17 {
 		final CollectorSink<TimestampObject> collectorSink = new CollectorSink<TimestampObject>(timestampObjects);
 
 		IPipe startPipe = new RelayTestPipe<TimestampObject>(this.numInputObjects, this.inputObjectCreator);
-		startPipe.setSignal(new TerminatingSignal());
+		startPipe.sendSignal(new TerminatingSignal());
 
 		relay.getInputPort().setPipe(startPipe);
 		UnorderedGrowablePipe.connect(relay.getOutputPort(), startTimestampFilter.getInputPort());

src/test/java/teetime/examples/pipe/SignalQueueTest.java

@@ -28,7 +28,7 @@ public class SignalQueueTest {
 
 		SpScPipe pipe = new SignalQueueConfiguration().pipe;
 		for (ISignal s : list) {
-			pipe.setSignal(s);
+			pipe.sendSignal(s);
 		}
 
 		ArrayList<ISignal> secondList = new ArrayList<ISignal>();