-
Notifications
You must be signed in to change notification settings - Fork 0
/
EventSubscribersLocator.php
43 lines (35 loc) · 1.24 KB
/
EventSubscribersLocator.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
<?php
declare(strict_types = 1);
namespace Nepada\MessageBus\Events;
use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Handler\HandlerDescriptor;
use Symfony\Component\Messenger\Handler\HandlersLocatorInterface;
final readonly class EventSubscribersLocator implements HandlersLocatorInterface
{
private ContainerInterface $container;
/**
* @var array<class-string, string[]>
*/
private array $serviceNamesByMessageType;
/**
* @param array<class-string, string[]> $serviceNamesByMessageType
*/
public function __construct(ContainerInterface $container, array $serviceNamesByMessageType)
{
$this->container = $container;
$this->serviceNamesByMessageType = $serviceNamesByMessageType;
}
/**
* @return iterable<int, HandlerDescriptor>
*/
public function getHandlers(Envelope $envelope): iterable
{
$messageType = get_class($envelope->getMessage());
foreach ($this->serviceNamesByMessageType[$messageType] ?? [] as $serviceName) {
$service = $this->container->get($serviceName);
assert(is_callable($service));
yield new HandlerDescriptor($service);
}
}
}