Commitfcfd60e

committed

[Messenger] Add suggestion for Amazon SQS transport and make check more readable

1 parent7950851 commitfcfd60eCopy full SHA for fcfd60e

File tree

-3

lines changed

-3

lines changed

Lines changed: 5 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -39,12 +39,14 @@ public function createTransport(string $dsn, array $options, SerializerInterface`
`39`	`39`
`40`	`40`	`// Help the user to select Symfony packages based on protocol.`
`41`	`41`	`$packageSuggestion ='';`
`42`		`-if ('amqp://' ===substr($dsn,0,7)) {`
	`42`	`+if (0 ===strpos($dsn,'amqp://')) {`
`43`	`43`	`$packageSuggestion =' Run "composer require symfony/amqp-messenger" to install AMQP transport.';`
`44`		`- }elseif ('doctrine://' ===substr($dsn,0,11)) {`
	`44`	`+ }elseif (0 ===strpos($dsn,'doctrine://')) {`
`45`	`45`	`$packageSuggestion =' Run "composer require symfony/doctrine-messenger" to install Doctrine transport.';`
`46`		`- }elseif ('redis://' ===substr($dsn,0,8)) {`
	`46`	`+ }elseif (0 ===strpos($dsn,'redis://')) {`
`47`	`47`	`$packageSuggestion =' Run "composer require symfony/redis-messenger" to install Redis transport.';`
	`48`	`+ }elseif (0 ===strpos($dsn,'sqs://')) {`
	`49`	`+$packageSuggestion =' Run "composer require symfony/amazon-sqs-messenger" to install Amazon SQS transport.';`
`48`	`50`	`}`
`49`	`51`
`50`	`52`	`thrownewInvalidArgumentException(sprintf('No transport supports the given Messenger DSN "%s".%s.',$dsn,$packageSuggestion));`

Comments

(0)