ソースを参照

Merge pull request #1206 from xando/master

BROKER_USE_SSL option added to mongodb backend
Mher Movsisyan 12 年 前
コミット
b37cea3d82
1 ファイル変更4 行追加1 行削除
  1. 4 1
      celery/backends/mongodb.py

+ 4 - 1
celery/backends/mongodb.py

@@ -96,7 +96,10 @@ class MongoBackend(BaseBackend):
             # This enables the use of replica sets and sharding.
             # See pymongo.Connection() for more info.
             args = [self.mongodb_host]
-            kwargs = {'max_pool_size': self.mongodb_max_pool_size}
+            kwargs = {
+                'max_pool_size': self.mongodb_max_pool_size,
+                'ssl': self.app.conf.BROKER_USE_SSL
+            }
             if isinstance(self.mongodb_host, string_t) \
                     and not self.mongodb_host.startswith('mongodb://'):
                 args.append(self.mongodb_port)