feat: check if secure connection is enabled before setting SSL options

Author: algins

src/Connectors/RabbitMQConnector.php

@@ -33,11 +33,13 @@ public function connect(array $config = []): Queue
         $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);