diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java index 8109682..19cf17f 100644 --- a/src/main/java/altk/comm/engine/Broadcast.java +++ b/src/main/java/altk/comm/engine/Broadcast.java @@ -350,7 +350,7 @@ public abstract class Broadcast continue; } } - updateServiceActivityCount(batchSize); + updateServiceActivityCount(batch.size()); } // Process jobs.