diff --git a/src/main/java/altk/comm/engine/CommEngine.java b/src/main/java/altk/comm/engine/CommEngine.java index 3b2713e..05a87d9 100644 --- a/src/main/java/altk/comm/engine/CommEngine.java +++ b/src/main/java/altk/comm/engine/CommEngine.java @@ -257,7 +257,8 @@ public abstract class CommEngine extends HttpServlet while (iter.hasNext()) { Broadcast broadcast = broadcasts.get(iter.next()); - if (now - broadcast.changeStateTime > deadBroadcastViewingMinutes * 60 * 1000) + if (broadcast.getState().isFinal && + now - broadcast.changeStateTime > deadBroadcastViewingMinutes * 60 * 1000) { completedJobCount += broadcast.getCompletedJobCount(); iter.remove();