diff --git a/pkg/pheanstalk/PheanstalkConsumer.php b/pkg/pheanstalk/PheanstalkConsumer.php index 337b77d9d..bfd9fb3b0 100644 --- a/pkg/pheanstalk/PheanstalkConsumer.php +++ b/pkg/pheanstalk/PheanstalkConsumer.php @@ -88,11 +88,13 @@ public function acknowledge(Message $message): void */ public function reject(Message $message, bool $requeue = false): void { - $this->acknowledge($message); - if ($requeue) { $this->pheanstalk->release($message->getJob(), $message->getPriority(), $message->getDelay()); + + return; } + + $this->acknowledge($message); } private function convertJobToMessage(Job $job): PheanstalkMessage