vendor/symfony/messenger/Transport/Sender/SendersLocator.php line 54

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.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. namespace Symfony\Component\Messenger\Transport\Sender;
  14. use Psr\Container\ContainerInterface;
  15. use Symfony\Component\Messenger\Envelope;
  16. use Symfony\Component\Messenger\Exception\RuntimeException;
  17. use Symfony\Component\Messenger\Handler\HandlersLocator;
  19. /**
  20.  * Maps a message to a list of senders.
  21.  *
  22.  * @author Fabien Potencier <fabien@symfony.com>
  23.  */
  24. class SendersLocator implements SendersLocatorInterface
  25. {
  26.     private $sendersMap;
  27.     private $sendersLocator;
  29.     /**
  30.      * @param array<string, list<string>> $sendersMap     An array, keyed by "type", set to an array of sender aliases
  31.      * @param ContainerInterface          $sendersLocator Locator of senders, keyed by sender alias
  32.      */
  33.     public function __construct(array $sendersMap, ContainerInterface $sendersLocator)
  34.     {
  35.         $this->sendersMap = $sendersMap;
  36.         $this->sendersLocator = $sendersLocator;
  37.     }
  39.     /**
  40.      * {@inheritdoc}
  41.      */
  42.     public function getSenders(Envelope $envelope): iterable
  43.     {
  44.         $seen = [];
  46.         foreach (HandlersLocator::listTypes($envelope) as $type) {
  47.             foreach ($this->sendersMap[$type] ?? [] as $senderAlias) {
  48.                 if (!\in_array($senderAlias, $seen, true)) {
  49.                     if (!$this->sendersLocator->has($senderAlias)) {
  50.                         throw new RuntimeException(sprintf('Invalid senders configuration: sender "%s" is not in the senders locator.', $senderAlias));
  51.                     }
  53.                     $seen[] = $senderAlias;
  54.                     $sender = $this->sendersLocator->get($senderAlias);
  55.                     yield $senderAlias => $sender;
  56.                 }
  57.             }
  58.         }
  59.     }
  60. }