Merge pull request #554 from maximetassy/add-network-protocol

Fix #553, add possibility to define network protocol in config

README.md

@@ -509,6 +509,26 @@ If for some reason you don't want the connection lazy you can turn it off by set
 ],
 ```
 
+### Network Protocol
+
+By default, the network protocol used for connection is tcp.
+If for some reason you want to use another network protocol, you can add the extra value in your config options.
+Available protocols : `tcp`, `ssl`, `tls`
+
+```php
+'connections' => [
+    // ...
+
+    'rabbitmq' => [
+        // ...
+
+        'network_protocol' => 'tcp',
+    ],
+
+    // ...    
+],
+```
+
 ### Octane support
 
 Starting with 13.3.0, this package supports [Laravel Octane](https://laravel.com/docs/octane) out of the box.

src/Queue/Connection/ConfigFactory.php

@@ -37,6 +37,7 @@ public static function make(array $config = []): AMQPConnectionConfig
 
             self::getHostFromConfig($connectionConfig, $config);
             self::getHeartbeatFromConfig($connectionConfig, $config);
+            self::getNetworkProtocolFromConfig($connectionConfig, $config);
         });
     }
 
@@ -90,4 +91,11 @@ protected static function getHeartbeatFromConfig(AMQPConnectionConfig $connectio
             $connectionConfig->setHeartbeat((int) $heartbeat);
         }
     }
+
+    protected static function getNetworkProtocolFromConfig(AMQPConnectionConfig $connectionConfig, array $config): void
+    {
+        if ($networkProtocol = Arr::get($config, 'network_protocol')) {
+            $connectionConfig->setNetworkProtocol($networkProtocol);
+        }
+    }
 }