src/Messenger/Query/MessengerQueryBus.php line 22

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\Messenger\Query;
  7. use Symfony\Component\Messenger\MessageBusInterface;
  8. use Symfony\Component\Messenger\Stamp\HandledStamp;
  10. final class MessengerQueryBus implements QueryBusInterface
  11. {
  12.     private MessageBusInterface $messageBus;
  14.     public function __construct(MessageBusInterface $messageBus)
  15.     {
  16.         $this->messageBus = $messageBus;
  17.     }
  19.     /**
  20.      * @return mixed
  21.      */
  22.     public function handle(QueryInterface $query)
  23.     {
  24.         $envelope = $this->messageBus->dispatch($query);
  25.         /** @var HandledStamp[] $handledStamps */
  26.         $handledStamps = $envelope->all(HandledStamp::class);
  27.         $countOfHandledStamps = \count($handledStamps);
  29.         if ($countOfHandledStamps === 0) {
  30.             throw InvalidQueryHandlerCountException::zero($envelope);
  31.         }
  33.         if ($countOfHandledStamps > 1) {
  34.             $handlerNames = \array_map(
  35.                 static fn (HandledStamp $stamp): string => \sprintf('"%s"', $stamp->getHandlerName()),
  36.                 $handledStamps,
  37.             );
  39.             throw InvalidQueryHandlerCountException::moreThanOne($envelope, $countOfHandledStamps, $handlerNames);
  40.         }
  42.         return $handledStamps[0]->getResult();
  43.     }
  44. }