summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/BroadcasterImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main/java/com/orbekk/same/BroadcasterImpl.java')
-rw-r--r--same/src/main/java/com/orbekk/same/BroadcasterImpl.java3
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) {