Merge pull request #264 from php-enqueue/consumption-message-not-set-…

…to-context [consumption] fix context is missing message on exception.
php-enqueue · Nov 11, 2017 · cca480a · cca480a
2 parents a7856c5 + 85aa4d4
commit cca480a
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 */