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 44 45 46 47 <?php
/*
* This file is part of the ICanBoogie package.
*
* (c) Olivier Laviale <olivier.laviale@gmail.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace ICanBoogie\MessageBus;
/**
* A simple implementation of {@link MessageHandlerProvider}.
*/
class SimpleMessageHandlerProvider implements MessageHandlerProvider
{
/**
* @var array
*/
private $handlers;
/**
* @param MessageHandler[]|callable[] $handlers
*/
public function __construct(array $handlers)
{
$this->handlers = $handlers;
}
/**
* @inheritdoc
*/
public function __invoke(Message $message)
{
$class = get_class($message);
if (empty($this->handlers[$class]))
{
throw new NoHandlerForMessage($message);
}
return $this->handlers[$class];
}
}