Change Broadcaster factory method.

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,