Browse Source

Fix bug of failing to requeue on 0 requeue delay.

tags/1.0.2
Yuk-Ming Lam 4 years ago
parent
commit
0b5c1548af
1 changed files with 2 additions and 3 deletions
  1. +2
    -3
      src/main/java/altk/comm/engine/Broadcast.java

+ 2
- 3
src/main/java/altk/comm/engine/Broadcast.java View File

@@ -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);


Loading…
Cancel
Save