[consumption] fix context is missing message on exception.

php-enqueue · Nov 10, 2017 · 85aa4d4 · 85aa4d4
1 parent bfd01d8
commit 85aa4d4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 */