Merge pull request #55 from iheartradio/feature/IHRACP-3256_ssl

Add SSL support
iheartradio · Jan 21, 2021 · 420389b · 420389b
2 parents 1a2b505 + 89b032a
commit 420389b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/henson_amqp/__init__.py b/henson_amqp/__init__.py
@@ -116,6 +116,7 @@ async def _begin_consuming(self):
             virtualhost=self.app.settings['AMQP_VIRTUAL_HOST'],
             heartbeat=self.app.settings['AMQP_HEARTBEAT_INTERVAL'],
             on_error=self._connection_error_callback,
+            ssl=self.app.settings['AMQP_USE_SSL'],
             login_method='PLAIN',
             **self.app.settings['AMQP_CONNECTION_KWARGS']
         )
@@ -236,6 +237,7 @@ async def _connect(self):
             password=self.app.settings['AMQP_PASSWORD'],
             virtualhost=self.app.settings['AMQP_VIRTUAL_HOST'],
             heartbeat=self.app.settings['AMQP_HEARTBEAT_INTERVAL'],
+            ssl=self.app.settings['AMQP_USE_SSL'],
             **self.app.settings['AMQP_CONNECTION_KWARGS']
         )
         self._channel = await self._protocol.channel()
@@ -315,6 +317,7 @@ class AMQP(Extension):
         'AMQP_VIRTUAL_HOST': '/',
         'AMQP_HEARTBEAT_INTERVAL': 60,
         'AMQP_CONNECTION_KWARGS': {},
+        'AMQP_USE_SSL': False,
 
         # Consumer settings
         'REGISTER_CONSUMER': False,