From 0b5c1548af835a5c03dbb3957d452a8d6f05a80f Mon Sep 17 00:00:00 2001 From: Yuk-Ming Lam Date: Sat, 6 Feb 2021 01:35:10 -0500 Subject: [PATCH] Fix bug of failing to requeue on 0 requeue delay. --- src/main/java/altk/comm/engine/Broadcast.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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);