fixed

workbunny · Jun 3, 2024 · 9e5299f · 9e5299f
1 parent 80df77f
commit 9e5299f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Builders/Traits/MessageQueueMethod.php b/src/Builders/Traits/MessageQueueMethod.php
@@ -397,10 +397,12 @@ public function consume(Worker $worker, bool $del = true): bool
             if (!$this->_init) {
                 foreach ($queues as $queueName) {
                     $client->xGroup('CREATE', $queueName, $groupName,'0', true);
-                    $queueStreams[$queueName] = '>';
                 }
                 $this->_init = true;
             }
+            foreach ($queues as $queueName) {
+                $queueStreams[$queueName] = '>';
+            }
             // group read
             if($res = $client->xReadGroup(
                 $groupName, $consumerName, $queueStreams, $builderConfig->getPrefetchCount(),