just work on the next message based on priority and published_at

Author: Henning

pkg/dbal/DbalSubscriptionConsumer.php

@@ -94,16 +94,11 @@ public function consume(int $timeout = 0): void
         $now = time();
         $redeliveryDelay = $this->getRedeliveryDelay() / 1000; // milliseconds to seconds
 
-        $currentQueueNames = [];
         while (true) {
-            if (empty($currentQueueNames)) {
-                $currentQueueNames = $queueNames;
-            }
-
             $this->removeExpiredMessages();
             $this->redeliverMessages();
 
-            if ($message = $this->fetchMessage($currentQueueNames, $redeliveryDelay)) {
+            if ($message = $this->fetchMessage($queueNames, $redeliveryDelay)) {
                 /**
                  * @var DbalConsumer
                  * @var callable     $callback
@@ -113,11 +108,7 @@ public function consume(int $timeout = 0): void
                 if (false === call_user_func($callback, $message, $consumer)) {
                     return;
                 }
-
-                unset($currentQueueNames[$message->getQueue()]);
             } else {
-                $currentQueueNames = [];
-
                 usleep($this->getPollingInterval() * 1000);
             }