add support for amqps (ssl connections) (#23)

redshark1802 · web-flow · commit 38096cd8e1a5 · 2020-03-18T11:17:14.000+02:00
diff --git a/RabbitMq/AMQPConnectionFactory.php b/RabbitMq/AMQPConnectionFactory.php
@@ -119,7 +119,7 @@ private function parseUrl(array $parameters)
 
         $url = parse_url($parameters['url']);
 
-        if ($url === false || !isset($url['scheme']) || $url['scheme'] !== 'amqp') {
+        if ($url === false || !isset($url['scheme']) || !in_array($url['scheme'], ['amqp', 'amqps'], true)) {
             throw new InvalidConfigurationException('Malformed parameter "url".');
         }
 

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ private function parseUrl(array $parameters)`
`119`	`119`
`120`	`120`	`$url = parse_url($parameters['url']);`
`121`	`121`
`122`		`- if ($url === false \|\| !isset($url['scheme']) \|\| $url['scheme'] !== 'amqp') {`
	`122`	`+ if ($url === false \|\| !isset($url['scheme']) \|\| !in_array($url['scheme'], ['amqp', 'amqps'], true)) {`
`123`	`123`	`throw new InvalidConfigurationException('Malformed parameter "url".');`
`124`	`124`	`}`
`125`	`125`