BUGFIX: Do not return message if timeout occured

Flowpack · Oct 5, 2018 · 11db963 · 11db963
1 parent 664fc64
commit 11db963
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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);
     }