solved some warnings

src/main/java/teetime/framework/AbstractPort.java

@@ -19,7 +19,7 @@ import teetime.framework.pipe.IPipe;
 
 public abstract class AbstractPort<T> {
 
-	protected IPipe pipe;
+	protected IPipe<?> pipe;
 	/**
 	 * The type of this port.
 	 * <p>
@@ -45,11 +45,11 @@ public abstract class AbstractPort<T> {
 		return owningStage;
 	}
 
-	public IPipe getPipe() {
+	public IPipe<?> getPipe() {
 		return this.pipe;
 	}
 
-	public void setPipe(final IPipe pipe) {
+	public void setPipe(final IPipe<?> pipe) {
 		this.pipe = pipe;
 	}
 

src/main/java/teetime/stage/InputPortSizePrinter.java

@@ -39,7 +39,7 @@ public class InputPortSizePrinter<T> extends AbstractConsumerStage<T> {
 		stopWatch.end();
 		if (stopWatch.getDurationInNs() >= thresholdInNs) {
 			if (logger.isDebugEnabled()) {
-				final IPipe pipe = inputPort.getPipe();
+				final IPipe<?> pipe = inputPort.getPipe();
 				logger.debug("pipe size: " + pipe.size());
 			}
 			stopWatch.start();

src/main/java/teetime/stage/basic/AbstractTrigger.java

@@ -21,9 +21,9 @@ import teetime.framework.OutputPort;
 
 abstract class AbstractTrigger<I, T, O> extends AbstractStage {
 
-	private final InputPort<I> inputPort = createInputPort();
-	private final InputPort<T> triggerInputPort = createInputPort();
-	private final OutputPort<O> outputPort = createOutputPort();
+	protected final InputPort<I> inputPort = createInputPort();
+	protected final InputPort<T> triggerInputPort = createInputPort();
+	protected final OutputPort<O> outputPort = createOutputPort();
 
 	protected AbstractTrigger() {
 		super();

src/main/java/teetime/stage/string/Tokenizer.java

@@ -15,8 +15,6 @@
  */
 package teetime.stage.string;
 
-import java.util.regex.Pattern;
-
 import teetime.framework.AbstractConsumerStage;
 import teetime.framework.OutputPort;
 
@@ -24,11 +22,11 @@ public final class Tokenizer extends AbstractConsumerStage<String> {
 
 	private final OutputPort<String> outputPort = this.createOutputPort();
 	private final String regex;
-	private final Pattern pattern;
+	// private final Pattern pattern;
 
 	public Tokenizer(final String regex) {
 		this.regex = regex;
-		pattern = Pattern.compile(regex);
+		// pattern = Pattern.compile(regex);
 	}
 
 	@Override

src/main/java/teetime/util/framework/concurrent/SignalingCounter.java

@@ -40,7 +40,7 @@ public class SignalingCounter {
 		if (conditions.containsKey(number)) {
 			Object cond = conditions.get(number);
 			synchronized (cond) {
-				cond.notifyAll();
+				cond.notifyAll(); // If you came here because of FindBugs, go on, everything's ok here. You saw nothing!
 			}
 		}
 	}

src/test/java/teetime/framework/pipe/UnsynchedPipeTest.java

@@ -23,7 +23,7 @@ public class UnsynchedPipeTest {
 
 	@Test(expected = IllegalArgumentException.class)
 	public void testAdd() throws Exception {
-		UnsynchedPipe pipe = new UnsynchedPipe(null, null);
+		UnsynchedPipe<Object> pipe = new UnsynchedPipe<Object>(null, null);
 		assertFalse(pipe.add(null));
 	}
 

src/test/java/teetime/stage/io/PrinterTest.java

@@ -29,6 +29,7 @@ import teetime.stage.basic.merger.Merger;
 
 public class PrinterTest {
 
+	@SuppressWarnings("unchecked")
 	@Test
 	public void testDefaultUsage() {
 		Printer<Merger<Object>> printer = new Printer<Merger<Object>>();

src/test/java/teetime/stage/taskfarm/monitoring/extraction/ExtractionTestInputPort.java

@@ -29,7 +29,7 @@ class ExtractionTestInputPort<T> extends InputPort<T> {
 	}
 
 	@Override
-	public IPipe getPipe() {
+	public IPipe<?> getPipe() {
 		return inputPipe;
 	}