We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5df95c6 commit 3456e77Copy full SHA for 3456e77
pkg/enqueue/Consumption/QueueConsumer.php
@@ -178,7 +178,13 @@ public function consume(ExtensionInterface $runtimeExtension = null)
178
$context = new Context($this->psrContext);
179
$this->extension->onStart($context);
180
181
- $this->logger = $context->getLogger() ?: new NullLogger();
+ if ($context->getLogger()) {
182
+ $this->logger = $context->getLogger();
183
+ } else {
184
+ $this->logger = new NullLogger();
185
+ $context->setLogger($this->logger);
186
+ }
187
+
188
$this->logger->info('Start consuming');
189
190
if ($this->psrContext instanceof AmqpContext) {
0 commit comments