File tree 1 file changed +6
-6
lines changed
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:
61
61
62
62
namespace Acme\Module\Helper\Async;
63
63
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 ;
67
67
68
68
class Foo implements Processor
69
69
{
70
- public function process(Message $message, Context $context)
70
+ public function process(PsrMessage $message, PsrContext $context)
71
71
{
72
72
// do job
73
73
// $message->getBody() -> 'payload'
@@ -83,15 +83,15 @@ than subscribe it to a topic or several topics:
83
83
84
84
85
85
``` xml
86
- <!-- app/etc/local .xml -->
86
+ <!-- app/code/Acme/Module/ etc/config .xml -->
87
87
88
88
<config >
89
89
<default >
90
90
<enqueue >
91
91
<processors >
92
92
<foo-processor >
93
93
<topic >a_topic</topic >
94
- <helper >acme/async_foo </helper >
94
+ <helper >Acme\Module\Helper\Async\foo </helper >
95
95
</foo-processor >
96
96
</processors >
97
97
</enqueue >
You can’t perform that action at this time.
0 commit comments