diff --git a/pkg/enqueue/Consumption/QueueConsumer.php b/pkg/enqueue/Consumption/QueueConsumer.php
index a44640373..7f484044e 100644
--- a/pkg/enqueue/Consumption/QueueConsumer.php
+++ b/pkg/enqueue/Consumption/QueueConsumer.php
@@ -178,7 +178,13 @@ public function consume(ExtensionInterface $runtimeExtension = null)
         $context = new Context($this->psrContext);
         $this->extension->onStart($context);
 
-        $this->logger = $context->getLogger() ?: new NullLogger();
+        if ($context->getLogger()) {
+            $this->logger = $context->getLogger();
+        } else {
+            $this->logger = new NullLogger();
+            $context->setLogger($this->logger);
+        }
+
         $this->logger->info('Start consuming');
 
         if ($this->psrContext instanceof AmqpContext) {