Skip to content

Commit 1783753

Browse files
committed
fix doc.
1 parent f304467 commit 1783753

File tree

1 file changed

+1
-50
lines changed

1 file changed

+1
-50
lines changed

docs/bundle/async_events.md

Lines changed: 1 addition & 50 deletions
Original file line numberDiff line numberDiff line change
@@ -68,60 +68,11 @@ services:
6868
acme.async_foo_listener:
6969
class: 'Enqueue\AsyncEventDispatcher\AsyncListener'
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\AsyncEventDispatcher\Registry;
82-
use Enqueue\Client\TopicSubscriberInterface;
83-
use Enqueue\Psr\PsrContext;
84-
use Enqueue\Psr\PsrMessage;
85-
use Enqueue\Psr\PsrProcessor;
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

Comments
 (0)