From 2ac5ac24a954f5edde530f5895961d8897e3e031 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Mon, 16 Jan 2012 20:28:01 +0100 Subject: Change Broadcaster factory method. --- same/src/main/java/com/orbekk/same/BroadcasterImpl.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'same') diff --git a/same/src/main/java/com/orbekk/same/BroadcasterImpl.java b/same/src/main/java/com/orbekk/same/BroadcasterImpl.java index 688a388..9ad7296 100644 --- a/same/src/main/java/com/orbekk/same/BroadcasterImpl.java +++ b/same/src/main/java/com/orbekk/same/BroadcasterImpl.java @@ -4,16 +4,17 @@ import java.util.List; import java.util.concurrent.Executor; import java.util.concurrent.Executors; -public class BroadcasterImpl { +public class BroadcasterImpl implements Broadcaster { private ConnectionManager connections; private Executor executor; /** * Get a BroadcastRunner for ClientService using a thread pool of size 20. */ - public static BroadcasterImpl getDefaultBroadcastRunner() { + public static BroadcasterImpl getDefaultBroadcastRunner( + ConnectionManager connections) { return new BroadcasterImpl(Executors.newFixedThreadPool(20), - new ConnectionManagerImpl()); + connections); } public BroadcasterImpl(Executor executor, -- cgit v1.2.3