From 091a99dbc6c245d9b58b3705b662c40fc09496b2 Mon Sep 17 00:00:00 2001
From: Cenk Alti <cenkalti@gmail.com>
Date: Tue, 21 Jan 2020 10:33:26 +0300
Subject: [PATCH] add ssl flag for connection; fix #65

---
 kuyruk/config.py | 1 +
 kuyruk/kuyruk.py | 1 +
 2 files changed, 2 insertions(+)

diff --git a/kuyruk/config.py b/kuyruk/config.py
index 9c6e69b6..7732e033 100644
--- a/kuyruk/config.py
+++ b/kuyruk/config.py
@@ -35,6 +35,7 @@ class attributes. Additional attributes may be added by extensions.
     RABBIT_PASSWORD = 'guest'
     """RabbitMQ password."""
 
+    RABBIT_SSL = False
     RABBIT_HEARTBEAT = 60
     RABBIT_CONNECT_TIMEOUT = 5
     RABBIT_READ_TIMEOUT = 5
diff --git a/kuyruk/kuyruk.py b/kuyruk/kuyruk.py
index 4a877139..6ba3ec4f 100644
--- a/kuyruk/kuyruk.py
+++ b/kuyruk/kuyruk.py
@@ -80,6 +80,7 @@ def connection(self) -> Iterator[amqp.Connection]:
             write_timeout=self.config.RABBIT_WRITE_TIMEOUT,
             socket_settings=socket_settings,
             heartbeat=self.config.RABBIT_HEARTBEAT,
+            ssl=self.config.RABBIT_SSL,
         )
         conn.connect()
         logger.info('Connected to RabbitMQ')