diff --git a/pkg/enqueue/Client/SimpleClient.php b/pkg/enqueue/Client/SimpleClient.php index 957787cff..27f295cdb 100644 --- a/pkg/enqueue/Client/SimpleClient.php +++ b/pkg/enqueue/Client/SimpleClient.php @@ -112,6 +112,14 @@ public function consume(ExtensionInterface $runtimeExtension = null) $queueConsumer->consume($runtimeExtension); } + /** + * @return AmqpContext + */ + public function getContext() + { + return $this->context; + } + /** * @return QueueConsumer */