Resets broker configuration in case a third party broker crashes

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_broker
+        from brokers import ironmq
-        return ironmq_broker.IronMQBroker(list_key=list_key)
+        return ironmq.IronMQBroker(list_key=list_key)
     # default to redis
     else:
         from brokers import redis_broker

django_q/tests/test_cluster.py

@@ -18,11 +18,6 @@ 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):
         self.word_list = DEFAULT_WORDLIST
@@ -33,6 +28,9 @@ class WordClass(object):
 
 @pytest.fixture
 def broker():
+    Conf.DISQUE_NODES = None
+    Conf.IRON_MQ = None
+    Conf.DJANGO_REDIS = 'default'
     return get_broker()