diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java index eccc197..53739e1 100644 --- a/src/main/java/altk/comm/engine/Broadcast.java +++ b/src/main/java/altk/comm/engine/Broadcast.java @@ -1094,15 +1094,14 @@ public abstract class Broadcast postback.queueReport(report.toString()); } - if (rescheduleTimeMS <= 0 - // No more rescheduling on cancel, expire, or pause - || state == BroadcastState.CANCELING + if (state == BroadcastState.CANCELING || state == BroadcastState.CANCELED || state == BroadcastState.EXPIRED || state == BroadcastState.PAUSED || state == BroadcastState.PAUSING ) { + // No more rescheduling on cancel, expire, or pause completedJobCount++; logJobCount("Completed a job"); if (allDone() && state==BroadcastState.RUNNING) setState(BroadcastState.ALLDONE);