From d72bc2cd14b6f633160ff834d6830de86450ca49 Mon Sep 17 00:00:00 2001
From: Maksim Kotlyar <kotlyar.maksim@gmail.com>
Date: Mon, 9 Jan 2017 22:35:06 +0200
Subject: [PATCH] [consumption] Do not print "Switch to queue xxx" if queue the
 same.

---
 pkg/enqueue/Consumption/QueueConsumer.php | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/pkg/enqueue/Consumption/QueueConsumer.php b/pkg/enqueue/Consumption/QueueConsumer.php
index 89948c619..d65b73bf1 100644
--- a/pkg/enqueue/Consumption/QueueConsumer.php
+++ b/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);