* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Symfony\Component\Messenger\Transport\Sync; use Symfony\Component\Messenger\MessageBusInterface; use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface; use Symfony\Component\Messenger\Transport\TransportFactoryInterface; use Symfony\Component\Messenger\Transport\TransportInterface; /** * @author Ryan Weaver * * @implements TransportFactoryInterface */ class SyncTransportFactory implements TransportFactoryInterface { public function __construct( private MessageBusInterface $messageBus, ) { } public function createTransport(#[\SensitiveParameter] string $dsn, array $options, SerializerInterface $serializer): TransportInterface { return new SyncTransport($this->messageBus); } public function supports(#[\SensitiveParameter] string $dsn, array $options): bool { return str_starts_with($dsn, 'sync://'); } }