Skip to content

Commit 83fac4c

Browse files
committed
Added comments
1 parent 95c21de commit 83fac4c

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/Queue.php

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,8 +226,14 @@ protected function handleMessage($id, $message, $ttr, $attempt)
226226
{
227227
list($job, $error) = $this->unserializeMessage($message);
228228

229-
if ($attempt > 1 && !($job instanceof RetryableJobInterface)) {
230-
return false;
229+
// Handle aborted jobs without thrown error
230+
if ($attempt > 1) {
231+
if ($job instanceof RetryableJobInterface && !$job->canRetry($attempt, $error)) {
232+
return true;
233+
} else {
234+
// Non RetryableJobs can have a maximum of one attempt
235+
return true;
236+
}
231237
}
232238

233239
$event = new ExecEvent([

0 commit comments

Comments
 (0)