8000
We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a57252f commit 758539aCopy full SHA for 758539a
src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
@@ -346,10 +346,12 @@ public function get(): ?array
346
$queuedMessageCount = $this->rawCommand('ZCOUNT', 0, $now);
347
348
while ($queuedMessageCount--) {
349
- if (![$queuedMessage, $expiry] = $this->rawCommand('ZPOPMIN', 1)) {
+ if (!$message = $this->rawCommand('ZPOPMIN', 1)) {
350
break;
351
}
352
353
+ [$queuedMessage, $expiry] = $message;
354
+
355
if (\strlen($expiry) === \strlen($now) ? $expiry > $now : \strlen($expiry) < \strlen($now)) {
356
// if a future-placed message is popped because of a race condition with
357
// another running consumer, the message is readded to the queue
0 commit comments