diff --git a/src/main/java/teetime/framework/pipe/IPipeFactory.java b/src/main/java/teetime/framework/pipe/IPipeFactory.java
index 32ad20cc6330d1b0ef841e9862dc32a8f3723f8d..a37955e86dacd9e3dc61df0f902628d393306a67 100644
--- a/src/main/java/teetime/framework/pipe/IPipeFactory.java
+++ b/src/main/java/teetime/framework/pipe/IPipeFactory.java
@@ -10,16 +10,6 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
  */
 public interface IPipeFactory {
 
-	/**
-	 * @deprecated Use {@link #create(OutputPort, InputPort)} or {@link #create(OutputPort, InputPort, int)} instead
-	 *
-	 * @param capacity
-	 *            Number of elements the pipe can carry
-	 * @return instance of the created pipe
-	 */
-	@Deprecated
-	IPipe create(int capacity);
-
 	/**
 	 * Connects two stages with a pipe of default capacity.
 	 *
diff --git a/src/main/java/teetime/framework/pipe/OrderedGrowableArrayPipeFactory.java b/src/main/java/teetime/framework/pipe/OrderedGrowableArrayPipeFactory.java
index 9142b80e11d7cbcfe4cd057f857840bf167ae9ab..ce5c89d844ed5b1458cd9317803e125db6991aff 100644
--- a/src/main/java/teetime/framework/pipe/OrderedGrowableArrayPipeFactory.java
+++ b/src/main/java/teetime/framework/pipe/OrderedGrowableArrayPipeFactory.java
@@ -7,11 +7,6 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
 
 public class OrderedGrowableArrayPipeFactory implements IPipeFactory {
 
-	@Override
-	public IPipe create(final int capacity) {
-		return create(null, null, capacity);
-	}
-
 	@Override
 	public <T> IPipe create(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
 		return create(sourcePort, targetPort, 4);
diff --git a/src/main/java/teetime/framework/pipe/SingleElementPipeFactory.java b/src/main/java/teetime/framework/pipe/SingleElementPipeFactory.java
index b51000fab0dc391fcb2c627cc3089e3508a5044d..7a76c7448953b793cc762241e6b879c18be93051 100644
--- a/src/main/java/teetime/framework/pipe/SingleElementPipeFactory.java
+++ b/src/main/java/teetime/framework/pipe/SingleElementPipeFactory.java
@@ -7,14 +7,6 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
 
 public class SingleElementPipeFactory implements IPipeFactory {
 
-	/**
-	 * Hint: The capacity for this pipe implementation is ignored
-	 */
-	@Override
-	public IPipe create(final int capacity) {
-		return create(null, null);
-	}
-
 	@Override
 	public <T> IPipe create(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
 		return create(sourcePort, targetPort, 1);
diff --git a/src/main/java/teetime/framework/pipe/SpScPipeFactory.java b/src/main/java/teetime/framework/pipe/SpScPipeFactory.java
index 745e79715025cb5e4d5ad6690f1d6ba7c5265147..88e4d59bbe0389afc39171e427c1cd2fc2d168ae 100644
--- a/src/main/java/teetime/framework/pipe/SpScPipeFactory.java
+++ b/src/main/java/teetime/framework/pipe/SpScPipeFactory.java
@@ -7,11 +7,6 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
 
 public class SpScPipeFactory implements IPipeFactory {
 
-	@Override
-	public IPipe create(final int capacity) {
-		return create(null, null, capacity);
-	}
-
 	@Override
 	public <T> IPipe create(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
 		return create(sourcePort, targetPort, 4);
diff --git a/src/main/java/teetime/framework/pipe/UnorderedGrowablePipeFactory.java b/src/main/java/teetime/framework/pipe/UnorderedGrowablePipeFactory.java
index 219d95d796c6d688dbf09e8356c283bd24ac75c3..7809347aa36c4d10269add05055d7051a6b96c64 100644
--- a/src/main/java/teetime/framework/pipe/UnorderedGrowablePipeFactory.java
+++ b/src/main/java/teetime/framework/pipe/UnorderedGrowablePipeFactory.java
@@ -7,14 +7,6 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
 
 public class UnorderedGrowablePipeFactory implements IPipeFactory {
 
-	/**
-	 * Hint: The capacity for this pipe implementation is ignored
-	 */
-	@Override
-	public IPipe create(final int capacity) {
-		return create(null, null, capacity);
-	}
-
 	@Override
 	public <T> IPipe create(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
 		return create(sourcePort, targetPort, 4);