@@ -68,60 +68,11 @@ services:
6868 acme.async_foo_listener:
6969 class: 'Enqueue\A syncEventDispatcher\A syncListener'
7070 public: false
71- arguments: ['@enqueue.client.producer ', '@enqueue.events.registry']
71+ arguments: ['@enqueue.transport.default.context ', '@enqueue.events.registry', 'a_queue_name ']
7272 tags:
7373 - { name: 'kernel.event_listener', event: 'foo', method: 'onEvent' }
7474` ` `
7575
76- The message processor must subscribe to `event.foo` topic. The message queue topics names for event follow this patter `event.{eventName}`.
77-
78- ` ` ` php
79- <?php
80-
81- use Enqueue\A syncEventDispatcher\R egistry;
82- use Enqueue\C lient\T opicSubscriberInterface;
83- use Enqueue\P sr\P srContext;
84- use Enqueue\P sr\P srMessage;
85- use Enqueue\P sr\P srProcessor;
86-
87- class FooEventProcessor implements PsrProcessor, TopicSubscriberInterface
88- {
89- /**
90- * @var Registry
91- */
92- private $registry;
93-
94- /**
95- * @param Registry $registry
96- */
97- public function __construct(Registry $registry)
98- {
99- $this->registry = $registry;
100- }
101-
102- public function process(PsrMessage $message, PsrContext $context)
103- {
104- if (false == $eventName = $message->getProperty('event_name')) {
105- return self::REJECT;
106- }
107- if (false == $transformerName = $message->getProperty('transformer_name')) {
108- return self::REJECT;
109- }
110-
111- // do what you want with the event.
112- $event = $this->registry->getTransformer($transformerName)->toEvent($eventName, $message);
113-
114-
115- return self::ACK;
116- }
117-
118- public static function getSubscribedTopics()
119- {
120- return ['event.foo'];
121- }
122- }
123- ` ` `
124-
12576
12677# # Event transformer
12778
0 commit comments