diff --git a/src/main/java/teetime/stage/io/EveryXthPrinter.java b/src/main/java/teetime/stage/io/EveryXthPrinter.java
index 1ca83ce56fd29af0167451efa8b0b69b57ed9b0b..c074dfd5c59835131b132d859d7a5a145bf0c23c 100644
--- a/src/main/java/teetime/stage/io/EveryXthPrinter.java
+++ b/src/main/java/teetime/stage/io/EveryXthPrinter.java
@@ -32,7 +32,7 @@ public final class EveryXthPrinter<T> extends AbstractCompositeStage {
 	private final List<Stage> lastStages = new ArrayList<Stage>();
 
 	public EveryXthPrinter(final int threshold) {
-		distributor = new Distributor<T>();
+		distributor = new Distributor<T>(new CopyByReferenceStrategy());
 		EveryXthStage<T> everyXthStage = new EveryXthStage<T>(threshold);
 		Printer<Integer> printer = new Printer<Integer>();
 
@@ -40,7 +40,6 @@ public final class EveryXthPrinter<T> extends AbstractCompositeStage {
 		connectPorts(everyXthStage.getOutputPort(), printer.getInputPort());
 
 		lastStages.add(printer);
-		distributor.setStrategy(new CopyByReferenceStrategy());
 	}
 
 	public InputPort<T> getInputPort() {