[consumption] Do not print "Switch to queue xxx" if queue the same.

Author: makasim

pkg/enqueue/Consumption/QueueConsumer.php

@@ -121,11 +121,16 @@ public function consume(ExtensionInterface $runtimeExtension = null)
         $logger = $context->getLogger() ?: new NullLogger();
         $logger->info('Start consuming');
 
+        /** @var Queue|null $previousQueue */
+        $previousQueue = null;
+
         while (true) {
             try {
                 /** @var Queue $queue */
                 foreach ($this->boundProcessors as list($queue, $processor)) {
-                    $logger->debug(sprintf('Switch to a queue %s', $queue->getQueueName()));
+                    if (false == $previousQueue || $previousQueue->getQueueName() != $queue->getQueueName()) {
+                        $logger->debug(sprintf('Switch to a queue %s', $queue->getQueueName()));
+                    }
 
                     $messageConsumer = $messageConsumers[$queue->getQueueName()];
 
@@ -136,6 +141,8 @@ public function consume(ExtensionInterface $runtimeExtension = null)
                     $context->setPsrProcessor($processor);
 
                     $this->doConsume($extension, $context);
+
+                    $previousQueue = $queue;
                 }
             } catch (ConsumptionInterruptedException $e) {
                 $logger->info(sprintf('Consuming interrupted'));
@@ -215,7 +222,7 @@ protected function doConsume(ExtensionInterface $extension, Context $context)
 
             $extension->onPostReceived($context);
         } else {
-            $logger->info(sprintf('Idle'));
+            $logger->debug(sprintf('Idle'));
 
             usleep($this->idleMicroseconds);
             $extension->onIdle($context);