vendor/api-platform/core/src/Symfony/Messenger/DispatchTrait.php line 44

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the API Platform project.
  5.  *
  6.  * (c) Kévin Dunglas <dunglas@gmail.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace ApiPlatform\Symfony\Messenger;
  16. use Symfony\Component\Messenger\Envelope;
  17. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  18. use Symfony\Component\Messenger\MessageBusInterface;
  20. /**
  21.  * @internal
  22.  */
  23. trait DispatchTrait
  24. {
  25.     /**
  26.      * @var MessageBusInterface|null
  27.      */
  28.     private $messageBus;
  30.     /**
  31.      * @param object|Envelope $message
  32.      */
  33.     private function dispatch($message)
  34.     {
  35.         if (!$this->messageBus instanceof MessageBusInterface) {
  36.             throw new \InvalidArgumentException('The message bus is not set.');
  37.         }
  39.         if (!class_exists(HandlerFailedException::class)) {
  40.             return $this->messageBus->dispatch($message);
  41.         }
  43.         try {
  44.             return $this->messageBus->dispatch($message);
  45.         } catch (HandlerFailedException $e) {
  46.             // unwrap the exception thrown in handler for Symfony Messenger >= 4.3
  47.             while ($e instanceof HandlerFailedException) {
  48.                 /** @var \Throwable $e */
  49.                 $e = $e->getPrevious();
  50.             }
  52.             throw $e;
  53.         }
  54.     }
  55. }
  57. class_alias(DispatchTrait::class, \ApiPlatform\Core\Bridge\Symfony\Messenger\DispatchTrait::class);