fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-06 06:08:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Adds custom broker configuration

Browse Source
This commit is contained in:
Ilan Steemers
2016-01-27 10:33:07 +01:00
parent 8298f2319f
commit fe8015403c
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/__init__.py
+10 -1
View File
@@ -1,6 +1,9 @@
from django_q.conf import Conf import importlib
from django.core.cache import caches, InvalidCacheBackendError from django.core.cache import caches, InvalidCacheBackendError
from django_q.conf import Conf
class Broker(object): class Broker(object):
def __init__(self, list_key=Conf.PREFIX): def __init__(self, list_key=Conf.PREFIX):
@@ -171,6 +174,12 @@ def get_broker(list_key=Conf.PREFIX):
elif Conf.MONGO: elif Conf.MONGO:
from brokers import mongo from brokers import mongo
return mongo.Mongo(list_key=list_key) return mongo.Mongo(list_key=list_key)
elif Conf.BROKER:
module, func = Conf.BROKER.rsplit('.', 1)
m = importlib.import_module(module)
broker = getattr(m, func)
return broker(list_key=list)
# default to redis # default to redis
else: else:
from brokers import redis_broker from brokers import redis_broker