File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ Transport gives you the access to all transport specific features so you can tun
1010
1111/** @var Symfony\Component\DependencyInjection\ContainerInterface $container */
1212
13- /** @var Enqueue\Psr \PsrContext $context */
13+ /** @var Interop\Queue \PsrContext $context */
1414$context = $container->get('enqueue.transport.context');
1515
1616$context->createProducer()->send(
Original file line number Diff line number Diff line change @@ -62,7 +62,7 @@ use Enqueue\Consumption\ChainExtension;
6262use Enqueue\Consumption\Extension\ReplyExtension;
6363use Enqueue\SimpleClient\SimpleClient;
6464
65- /** @var \Enqueue\Psr \PsrContext $context */
65+ /** @var \Interop\Queue \PsrContext $context */
6666
6767$client = new SimpleClient('amqp://');
6868
Original file line number Diff line number Diff line change @@ -119,7 +119,7 @@ class SendMailProcessor implements PsrProcessor
119119 }
120120}
121121
122- /** @var \Enqueue\Psr \PsrContext $psrContext */
122+ /** @var \Interop\Queue \PsrContext $psrContext */
123123
124124$queueConsumer = new QueueConsumer($psrContext, new ChainExtension([
125125 new ReplyExtension()
Original file line number Diff line number Diff line change @@ -99,7 +99,7 @@ use Enqueue\Consumption\QueueConsumer;
9999use Enqueue\Consumption\Extension\SignalExtension;
100100use Enqueue\Consumption\Extension\LimitConsumptionTimeExtension;
101101
102- /** @var \Enqueue\Psr \PsrContext $psrContext */
102+ /** @var \Interop\Queue \PsrContext $psrContext */
103103
104104$queueConsumer = new QueueConsumer($psrContext, new ChainExtension([
105105 new SignalExtension(),
@@ -116,7 +116,7 @@ You can do several calls asynchronously. This is how you can send a RPC message
116116<?php
117117use Enqueue\Rpc\RpcClient;
118118
119- /** @var \Enqueue\Psr \PsrContext $psrContext */
119+ /** @var \Interop\Queue \PsrContext $psrContext */
120120
121121$queue = $psrContext->createQueue('foo');
122122$message = $psrContext->createMessage('Hi there!');
@@ -139,7 +139,7 @@ use Enqueue\Consumption\QueueConsumer;
139139use Enqueue\Consumption\Extension\ReplyExtension;
140140use Enqueue\Consumption\Result;
141141
142- /** @var \Enqueue\Psr \PsrContext $psrContext */
142+ /** @var \Interop\Queue \PsrContext $psrContext */
143143
144144$queueConsumer = new QueueConsumer($psrContext, new ChainExtension([
145145 new ReplyExtension()
You can’t perform that action at this time.
0 commit comments