Merge pull request #6 from algins/feature-set-is-secure-flag

feat: make isSecure flag configurable

Author: iamfarhad

README.md

@@ -50,6 +50,7 @@ Add connection to config/queue.php:
                 'lazy'      => env('RABBITMQ_LAZY_CONNECTION', true),
                 'keepalive' => env('RABBITMQ_KEEPALIVE_CONNECTION', false),
                 'heartbeat' => env('RABBITMQ_HEARTBEAT_CONNECTION', 0),
+                'secure'    => env('RABBITMQ_SECURE', false),
             ],
 
             'options' => [

config/RabbitMQConnectionConfig.php

@@ -13,6 +13,7 @@
         'lazy' => env('RABBITMQ_LAZY_CONNECTION', true),
         'keepalive' => env('RABBITMQ_KEEPALIVE_CONNECTION', false),
         'heartbeat' => env('RABBITMQ_HEARTBEAT_CONNECTION', 0),
+        'secure' => env('RABBITMQ_SECURE', false),
     ],
 
     'options' => [

src/Connectors/RabbitMQConnector.php

@@ -30,13 +30,16 @@ public function connect(array $config = []): Queue
         $amqpConnectionConfig->setIsLazy(config('queue.connections.rabbitmq.hosts.lazy'));
         $amqpConnectionConfig->setKeepalive(config('queue.connections.rabbitmq.hosts.keepalive'));
         $amqpConnectionConfig->setHeartbeat(config('queue.connections.rabbitmq.hosts.heartbeat'));
+        $amqpConnectionConfig->setIsSecure(config('queue.connections.rabbitmq.hosts.secure'));
 
         // set SSL Options
-        $amqpConnectionConfig->setSslCaCert(config('queue.connections.rabbitmq.options.ssl_options.cafile'));
-        $amqpConnectionConfig->setSslCert(config('queue.connections.rabbitmq.options.ssl_options.local_cert'));
-        $amqpConnectionConfig->setSslKey(config('queue.connections.rabbitmq.options.ssl_options.local_key'));
-        $amqpConnectionConfig->setSslVerify(config('queue.connections.rabbitmq.options.ssl_options.verify_peer'));
-        $amqpConnectionConfig->setSslPassPhrase(config('queue.connections.rabbitmq.options.ssl_options.passphrase'));
+        if ($amqpConnectionConfig->isSecure()) {
+            $amqpConnectionConfig->setSslCaCert(config('queue.connections.rabbitmq.options.ssl_options.cafile'));
+            $amqpConnectionConfig->setSslCert(config('queue.connections.rabbitmq.options.ssl_options.local_cert'));
+            $amqpConnectionConfig->setSslKey(config('queue.connections.rabbitmq.options.ssl_options.local_key'));
+            $amqpConnectionConfig->setSslVerify(config('queue.connections.rabbitmq.options.ssl_options.verify_peer'));
+            $amqpConnectionConfig->setSslPassPhrase(config('queue.connections.rabbitmq.options.ssl_options.passphrase'));
+        }
 
         // Create AMQP Connection
         $connection = AMQPConnectionFactory::create($amqpConnectionConfig);