summaryrefslogtreecommitdiff
path: root/same/src/main/java/com
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-01-16 20:28:01 +0100
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-01-16 20:28:01 +0100
commit2ac5ac24a954f5edde530f5895961d8897e3e031 (patch)
tree97e2faf30fe5f0c73ddea283b3b300ebeb425e9f /same/src/main/java/com
parent654ac153d6d260ec4cf79e614a93fbcd40dc4659 (diff)
Change Broadcaster factory method.
Diffstat (limited to 'same/src/main/java/com')
-rw-r--r--same/src/main/java/com/orbekk/same/BroadcasterImpl.java7
1 files changed, 4 insertions, 3 deletions
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,