ssl option added to transport mongodb transport

2013-02-22 16:33:26 +01:00 · 2013-02-22 16:33:26 +01:00 · 22990089d5
parent 3b76530568
commit 22990089d5
1 changed files with 1 additions and 1 deletions
--- 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(