diff --git a/Classes/Queue/RedisQueue.php b/Classes/Queue/RedisQueue.php index 3b638f3..5243bda 100644 --- a/Classes/Queue/RedisQueue.php +++ b/Classes/Queue/RedisQueue.php @@ -134,6 +134,9 @@ public function waitAndReserve(?int $timeout = null): ?Message } $this->checkClientConnection(); $messageId = $this->client->brpoplpush("queue:{$this->name}:messages", "queue:{$this->name}:processing", $timeout); + if ($messageId === false) { + return null; + } return $this->getMessageById($messageId); }