Correctly handle the case where the AMQP SSL connection param parser gets params=None.

This commit is contained in:
Nate Coraor
2014-05-14 15:27:28 -05:00
parent d682e58ad4
commit 5e32a8ae5b
+3 -1
View File
@@ -65,7 +65,9 @@ def directory_files(directory):
def parse_amqp_connect_ssl_params(params):
ssl = None
rval = None
ssl_options = filter(lambda x: x.startswith('amqp_connect_ssl_'), params.keys())
ssl_options = []
if params:
ssl_options = filter(lambda x: x.startswith('amqp_connect_ssl_'), params.keys())
if ssl_options:
ssl = __import__('ssl')
rval = {}