diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index 60b6df66..1a09d1f4 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -133,7 +133,7 @@ class Channel(virtual.Channel): # # mongodb://[username:password@]host1[:port1][,host2[:port2], # ...[,hostN[:portN]]][/[?options]] - mongoconn = Connection(host=hostname) + mongoconn = Connection(host=hostname, ssl=conninfo.ssl) version = mongoconn.server_info()['version'] if tuple(map(int, version.split('.')[:2])) < (1, 3): raise NotImplementedError(