diff --git a/django_q/brokers/ironmq.py b/django_q/brokers/ironmq.py index d8b92ec..c79b88f 100644 --- a/django_q/brokers/ironmq.py +++ b/django_q/brokers/ironmq.py @@ -13,7 +13,7 @@ class IronMQBroker(Broker): t = self.task_cache.pop() else: timeout = Conf.RETRY or None - tasks = self.connection.get(timeout=timeout, wait=1, max=Conf.IRON_MQ_MAX)['messages'] + tasks = self.connection.get(timeout=timeout, wait=1, max=Conf.BULK)['messages'] if tasks: t = tasks.pop() if tasks: diff --git a/django_q/conf.py b/django_q/conf.py index 6128875..9463806 100644 --- a/django_q/conf.py +++ b/django_q/conf.py @@ -39,7 +39,6 @@ class Conf(object): # IronMQ broker IRON_MQ = conf.get('iron_mq', None) - IRON_MQ_MAX = conf.get('iron_mq_max', 1) # Name of the cluster or site. For when you run multiple sites on one redis server PREFIX = conf.get('name', 'default') @@ -81,6 +80,10 @@ class Conf(object): # Only works with brokers that guarantee delivery. Defaults to 60 seconds. RETRY = conf.get('retry', 60) + # Sets the amount of tasks the cluster will try to pop off the broker. + # If it supports bulk gets. + BULK = conf.get('bulk', 1) + # The Django Admin label for this app LABEL = conf.get('label', 'Django Q')