Browse Source

Merge pull request #1461 from aguinet/master

Add a BROKER_LOGIN_METHOD configuration directive
Ask Solem Hoel 11 years ago
parent
commit
cb7ca53a84
1 changed files with 1 additions and 0 deletions
  1. 1 0
      celery/app/base.py

+ 1 - 0
celery/app/base.py

@@ -308,6 +308,7 @@ class Celery(object):
             connect_timeout=self.either(
                 'BROKER_CONNECTION_TIMEOUT', connect_timeout),
             heartbeat=heartbeat,
+            login_method=self.either('BROKER_LOGIN_METHOD', None),
             transport_options=dict(conf.BROKER_TRANSPORT_OPTIONS,
                                    **transport_options or {}))
     broker_connection = connection