Merge pull request bschmitt#8 from CodeYellowBV/add-ssl-options

Add SSL options

README.md

@@ -55,6 +55,8 @@ return [
             'exchange'            => 'amq.topic',
             'exchange_type'       => 'topic',
             'consumer_tag'        => 'consumer',
+            'ssl_options'         => [], // See https://secure.php.net/manual/en/context.ssl.php
+            'connect_options'     => [], // See https://github.com/php-amqplib/php-amqplib/blob/master/PhpAmqpLib/Connection/AMQPSSLConnection.php
             'queue_properties'    => ['x-ha-policy' => ['S', 'all']],
             'exchange_properties' => [],
             'timeout'             => 0

config/amqp.php

@@ -29,9 +29,11 @@
             'consumer_tag'        => 'consumer',
             'queue_properties'    => ['x-ha-policy' => ['S', 'all']],
             'exchange_properties' => [],
+            'connect_options'     => [],
+            'ssl_options'         => [],
             'timeout'             => 0
         ],
 
     ],
 
-];
+];

src/Request.php

@@ -2,6 +2,7 @@
 
 use Illuminate\Config\Repository;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
+use PhpAmqpLib\Connection\AMQPSSLConnection;
 use PhpAmqpLib\Channel\AMQPChannel;
 
 /**
@@ -30,12 +31,14 @@ class Request extends Context
      */
     public function connect()
     {
-        $this->connection = new AMQPStreamConnection(
+        $this->connection = new AMQPSSLConnection(
             $this->getProperty('host'),
             $this->getProperty('port'),
             $this->getProperty('username'),
             $this->getProperty('password'),
-            $this->getProperty('vhost')
+            $this->getProperty('vhost'),
+            $this->getProperty('ssl_options'),
+            $this->getProperty('connect_options')
         );
 
         $this->channel = $this->connection->channel();