From 85aa4d4871434e7cb69c961ebd4b9289d57368b7 Mon Sep 17 00:00:00 2001 From: Maksim Kotlyar Date: Fri, 10 Nov 2017 17:29:09 +0200 Subject: [PATCH] [consumption] fix context is missing message on exception. --- pkg/enqueue/Consumption/QueueConsumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/enqueue/Consumption/QueueConsumer.php b/pkg/enqueue/Consumption/QueueConsumer.php index 4e59abcd8..275a1890e 100644 --- a/pkg/enqueue/Consumption/QueueConsumer.php +++ b/pkg/enqueue/Consumption/QueueConsumer.php @@ -171,7 +171,7 @@ public function consume(ExtensionInterface $runtimeExtension = null) while (true) { try { if ($this->psrContext instanceof AmqpContext) { - $callback = function (AmqpMessage $message, AmqpConsumer $consumer) use ($extension, $logger) { + $callback = function (AmqpMessage $message, AmqpConsumer $consumer) use ($extension, $logger, &$context) { $currentProcessor = null; /** @var PsrQueue $queue */