File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -61,13 +61,13 @@ To consume messages you have to define a processor class first:
6161
6262namespace Acme\Module\Helper\Async;
6363
64- use Interop\Queue\Context ;
65- use Interop\Queue\Message ;
66- use Interop\Queue\Processor ;
64+ use Interop\Queue\PsrContext ;
65+ use Interop\Queue\PsrMessage ;
66+ use Interop\Queue\PsrProcessor ;
6767
6868class Foo implements Processor
6969{
70- public function process(Message $message, Context $context)
70+ public function process(PsrMessage $message, PsrContext $context)
7171 {
7272 // do job
7373 // $message->getBody() -> 'payload'
@@ -83,15 +83,15 @@ than subscribe it to a topic or several topics:
8383
8484
8585``` xml
86- <!-- app/etc/local .xml -->
86+ <!-- app/code/Acme/Module/ etc/config .xml -->
8787
8888<config >
8989 <default >
9090 <enqueue >
9191 <processors >
9292 <foo-processor >
9393 <topic >a_topic</topic >
94- <helper >acme/async_foo </helper >
94+ <helper >Acme\Module\Helper\Async\foo </helper >
9595 </foo-processor >
9696 </processors >
9797 </enqueue >
You can’t perform that action at this time.
0 commit comments