forked from CodelyTV/php-ddd-example
-
Notifications
You must be signed in to change notification settings - Fork 0
/
SymfonySyncCommandBus.php
38 lines (32 loc) · 1.15 KB
/
SymfonySyncCommandBus.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
<?php
declare(strict_types = 1);
namespace CodelyTv\Shared\Infrastructure\Bus\Command;
use CodelyTv\Shared\Domain\Bus\Command\Command;
use CodelyTv\Shared\Domain\Bus\Command\CommandBus;
use CodelyTv\Shared\Infrastructure\Symfony\Bundle\DependencyInjection\Compiler\CallableFirstParameterExtractor;
use Symfony\Component\Messenger\Exception\NoHandlerForMessageException;
use Symfony\Component\Messenger\Handler\HandlersLocator;
use Symfony\Component\Messenger\MessageBus;
use Symfony\Component\Messenger\Middleware\HandleMessageMiddleware;
class SymfonySyncCommandBus implements CommandBus
{
private $bus;
public function __construct(iterable $commandHandlers)
{
$this->bus = new MessageBus(
[
new HandleMessageMiddleware(
new HandlersLocator(CallableFirstParameterExtractor::forCallables($commandHandlers))
),
]
);
}
public function dispatch(Command $command): void
{
try {
$this->bus->dispatch($command);
} catch (NoHandlerForMessageException $unused) {
throw new CommandNotRegisteredError($command);
}
}
}