Skip to content

Commit 7b48c32

Browse files
authored
fixed unacked message when class not found. (vyuldashev#314)
1 parent 16a4fb3 commit 7b48c32

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/Queue/Jobs/RabbitMQJob.php

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,14 +85,17 @@ public function attempts(): int
8585
return ($laravelAttempts) + 1;
8686
}
8787

88+
/**
89+
* @param null $e
90+
*/
8891
public function fail($e = null): void
8992
{
90-
parent::fail($e);
91-
9293
// We must tel rabbitMQ this Job is failed
9394
// The message must be rejected when the Job marked as failed, in case rabbitMQ wants to do some extra magic.
9495
// like: Death lettering the message to an other exchange/routing-key.
9596
$this->rabbitmq->reject($this);
97+
98+
parent::fail($e);
9699
}
97100

98101
/**

0 commit comments

Comments
 (0)