Raise exception if attempting to use SSL with librabbitmq

This commit is contained in:
Dan LaMotte 2013-04-11 13:01:18 -05:00 committed by Ask Solem
parent 856d693800
commit 68075277dc
1 changed files with 3 additions and 0 deletions

View File

@ -233,6 +233,9 @@ class Connection(object):
self.transport_cls = transport
self.heartbeat = heartbeat and float(heartbeat)
if ssl and transport == 'librabbitmq':
raise Exception('SSL not supported for "librabbitmq" transport')
def _debug(self, msg, *args, **kwargs):
fmt = '[Kombu connection:0x%(id)x] %(msg)s'
if self._logger: # pragma: no cover