diff options
Diffstat (limited to 'same/src/main/java/com/orbekk/same/BroadcasterImpl.java')
-rw-r--r-- | same/src/main/java/com/orbekk/same/BroadcasterImpl.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/same/src/main/java/com/orbekk/same/BroadcasterImpl.java b/same/src/main/java/com/orbekk/same/BroadcasterImpl.java index 5efdcf3..27b8539 100644 --- a/same/src/main/java/com/orbekk/same/BroadcasterImpl.java +++ b/same/src/main/java/com/orbekk/same/BroadcasterImpl.java @@ -13,11 +13,12 @@ public class BroadcasterImpl implements Broadcaster { public static BroadcasterImpl getDefaultBroadcastRunner() { return new BroadcasterImpl(Executors.newFixedThreadPool(20)); } - + public BroadcasterImpl(Executor executor) { this.executor = executor; } + @Override public synchronized void broadcast(final List<String> targets, final ServiceOperation operation) { for (final String t : targets) { |