vendor/symfony/messenger/Transport/TransportFactory.php line 32

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;
  14. use Symfony\Component\Messenger\Exception\InvalidArgumentException;
  15. use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
  17. /**
  18.  * @author Samuel Roze <samuel.roze@gmail.com>
  19.  */
  20. class TransportFactory implements TransportFactoryInterface
  21. {
  22.     private $factories;
  24.     /**
  25.      * @param iterable<mixed, TransportFactoryInterface> $factories
  26.      */
  27.     public function __construct(iterable $factories)
  28.     {
  29.         $this->factories = $factories;
  30.     }
  32.     public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
  33.     {
  34.         foreach ($this->factories as $factory) {
  35.             if ($factory->supports($dsn, $options)) {
  36.                 return $factory->createTransport($dsn, $options, $serializer);
  37.             }
  38.         }
  40.         // Help the user to select Symfony packages based on protocol.
  41.         $packageSuggestion = '';
  42.         if (0 === strpos($dsn, 'amqp://')) {
  43.             $packageSuggestion = ' Run "composer require symfony/amqp-messenger" to install AMQP transport.';
  44.         } elseif (0 === strpos($dsn, 'doctrine://')) {
  45.             $packageSuggestion = ' Run "composer require symfony/doctrine-messenger" to install Doctrine transport.';
  46.         } elseif (0 === strpos($dsn, 'redis://') || 0 === strpos($dsn, 'rediss://')) {
  47.             $packageSuggestion = ' Run "composer require symfony/redis-messenger" to install Redis transport.';
  48.         } elseif (0 === strpos($dsn, 'sqs://') || preg_match('#^https://sqs\.[\w\-]+\.amazonaws\.com/.+#', $dsn)) {
  49.             $packageSuggestion = ' Run "composer require symfony/amazon-sqs-messenger" to install Amazon SQS transport.';
  50.         } elseif (0 === strpos($dsn, 'beanstalkd://')) {
  51.             $packageSuggestion = ' Run "composer require symfony/beanstalkd-messenger" to install Beanstalkd transport.';
  52.         }
  54.         throw new InvalidArgumentException('No transport supports the given Messenger DSN.'.$packageSuggestion);
  55.     }
  57.     public function supports(string $dsn, array $options): bool
  58.     {
  59.         foreach ($this->factories as $factory) {
  60.             if ($factory->supports($dsn, $options)) {
  61.                 return true;
  62.             }
  63.         }
  65.         return false;
  66.     }
  67. }