From 9078904983c40cb9f9ef1a0c81ca56046b8e5c3f Mon Sep 17 00:00:00 2001 From: Max Kotliar Date: Thu, 26 Jul 2018 18:13:43 +0300 Subject: [PATCH] Fix call debug method on null --- pkg/enqueue/Consumption/QueueConsumer.php | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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) {