add ssl flag for connection; fix #65

cenkalti · Jan 21, 2020 · 091a99d · 091a99d
1 parent 9d43a83
commit 091a99d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git 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
@@ -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')