[consumption] Add ability to overwrite logger.

Author: makasim

pkg/enqueue/Consumption/Extension/LoggerExtension.php

@@ -31,8 +31,16 @@ public function __construct(LoggerInterface $logger)
      */
     public function onStart(Context $context)
     {
-        $context->setLogger($this->logger);
-        $this->logger->debug(sprintf('Set context\'s logger %s', get_class($this->logger)));
+        if ($context->getLogger()) {
+            $context->getLogger()->debug(sprintf(
+                'Skip setting context\'s logger "%s". Another one "%s" has already been set.',
+                get_class($context->getLogger()),
+                get_class($this->logger)
+            ));
+        } else {
+            $context->setLogger($this->logger);
+            $this->logger->debug(sprintf('Set context\'s logger "%s"', get_class($this->logger)));
+        }
     }
 
     /**

pkg/enqueue/Tests/Consumption/Extension/LoggerExtensionTest.php

@@ -151,6 +151,29 @@ public function testShouldNotLogAckMessageStatusIfReasonIsEmpty()
         $extension->onPostReceived($context);
     }
 
+    public function testShouldNotSetLoggerIfOneHasBeenSetOnStart()
+    {
+        $logger = $this->createLogger();
+
+        $alreadySetLogger = $this->createLogger();
+        $alreadySetLogger
+            ->expects($this->once())
+            ->method('debug')
+            ->with(sprintf(
+                'Skip setting context\'s logger "%s". Another one "%s" has already been set.',
+                get_class($logger),
+                get_class($alreadySetLogger)
+            ))
+        ;
+
+        $extension = new LoggerExtension($logger);
+
+        $context = new Context($this->createPsrContextMock());
+        $context->setLogger($alreadySetLogger);
+
+        $extension->onStart($context);
+    }
+
     /**
      * @return \PHPUnit_Framework_MockObject_MockObject|PsrContext
      */