Merge pull request #781 from Leprechaunz/ssl_on

Enable 'ssl_on' param for 'ssl' scheme extension

Author: makasim

pkg/amqp-tools/ConnectionConfig.php

@@ -49,7 +49,7 @@ class ConnectionConfig
     private $config;
 
     /**
-     * @var array|null|string
+     * @var array|string|null
      */
     private $inputConfig;
 
@@ -391,7 +391,10 @@ private function parseDsn($dsn)
         }
 
         $sslOn = false;
-        if ('amqps' === $dsn->getSchemeProtocol() || in_array('tls', $dsn->getSchemeExtensions(), true)) {
+        $isAmqps = 'amqps' === $dsn->getSchemeProtocol();
+        $isTls = in_array('tls', $dsn->getSchemeExtensions(), true);
+        $isSsl = in_array('ssl', $dsn->getSchemeExtensions(), true);
+        if ($isAmqps || $isTls || $isSsl) {
             $sslOn = true;
         }
 

pkg/amqp-tools/Tests/ConnectionConfigTest.php

@@ -266,6 +266,32 @@ public static function provideConfigs()
             ],
         ];
 
+        yield [
+            'amqp+ssl:',
+            [
+                'host' => 'localhost',
+                'port' => 5672,
+                'vhost' => '/',
+                'user' => 'guest',
+                'pass' => 'guest',
+                'read_timeout' => 3.,
+                'write_timeout' => 3.,
+                'connection_timeout' => 3.,
+                'persisted' => false,
+                'lazy' => true,
+                'qos_prefetch_size' => 0,
+                'qos_prefetch_count' => 1,
+                'qos_global' => false,
+                'heartbeat' => 0.0,
+                'ssl_on' => true,
+                'ssl_verify' => true,
+                'ssl_cacert' => '',
+                'ssl_cert' => '',
+                'ssl_key' => '',
+                'ssl_passphrase' => '',
+            ],
+        ];
+
         yield [
             'amqp://user:pass@host:10000/vhost',
             [