diff --git a/django_q/brokers/__init__.py b/django_q/brokers/__init__.py index 626717c..c1c3d08 100644 --- a/django_q/brokers/__init__.py +++ b/django_q/brokers/__init__.py @@ -155,8 +155,8 @@ def get_broker(list_key=Conf.PREFIX): from brokers import disque return disque.Disque(list_key=list_key) elif Conf.IRON_MQ: - from brokers import ironmq - return ironmq.IronMQBroker(list_key=list_key) + from brokers import ironmq_broker + return ironmq_broker.IronMQBroker(list_key=list_key) # default to redis else: from brokers import redis_broker diff --git a/django_q/brokers/ironmq.py b/django_q/brokers/ironmq_broker.py similarity index 97% rename from django_q/brokers/ironmq.py rename to django_q/brokers/ironmq_broker.py index c79b88f..fd47667 100644 --- a/django_q/brokers/ironmq.py +++ b/django_q/brokers/ironmq_broker.py @@ -1,4 +1,4 @@ -from django_q.conf import Conf, logger +from django_q.conf import Conf from django_q.brokers import Broker from iron_mq import IronMQ diff --git a/django_q/tests/test_cluster.py b/django_q/tests/test_cluster.py index 5df7bcb..e2ecd94 100644 --- a/django_q/tests/test_cluster.py +++ b/django_q/tests/test_cluster.py @@ -18,6 +18,10 @@ from django_q.status import Stat from django_q.brokers import get_broker from .tasks import multiply +Conf.DISQUE_NODES = None +Conf.IRON_MQ = None +Conf.DJANGO_REDIS = 'default' + class WordClass(object): def __init__(self):