vendor/symfony/redis-messenger/Transport/RedisTransportFactory.php line 24

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\Bridge\Redis\Transport;
  14. use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
  15. use Symfony\Component\Messenger\Transport\TransportFactoryInterface;
  16. use Symfony\Component\Messenger\Transport\TransportInterface;
  18. /**
  19.  * @author Alexander Schranz <alexander@suluio>
  20.  * @author Antoine Bluchet <soyuka@gmail.com>
  21.  */
  22. class RedisTransportFactory implements TransportFactoryInterface
  23. {
  24.     public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
  25.     {
  26.         unset($options['transport_name']);
  28.         return new RedisTransport(Connection::fromDsn($dsn, $options), $serializer);
  29.     }
  31.     public function supports(string $dsn, array $options): bool
  32.     {
  33.         return 0 === strpos($dsn, 'redis://') || 0 === strpos($dsn, 'rediss://');
  34.     }
  35. }
  37. if (!class_exists(\Symfony\Component\Messenger\Transport\RedisExt\RedisTransportFactory::class, false)) {
  38.     class_alias(RedisTransportFactory::class, \Symfony\Component\Messenger\Transport\RedisExt\RedisTransportFactory::class);
  39. }