changes py 2.7 import for ironmq

django_q/brokers/ironmq.py

@@ -1,51 +0,0 @@
-from django_q.conf import Conf, logger
-from django_q.brokers import Broker
-from iron_mq import IronMQ
-
-
-class IronMQBroker(Broker):
-    def enqueue(self, task):
-        return self.connection.post(task)['ids'][0]
-
-    def dequeue(self):
-        t = None
-        if len(self.task_cache) > 0:
-            t = self.task_cache.pop()
-        else:
-            timeout = Conf.RETRY or None
-            tasks = self.connection.get(timeout=timeout, wait=1, max=Conf.BULK)['messages']
-            if tasks:
-                t = tasks.pop()
-                if tasks:
-                    self.task_cache = tasks
-        if t:
-            return t['id'], t['body']
-
-    def ping(self):
-        return self.connection.name == self.list_key
-
-    def info(self):
-        return 'IronMQ'
-
-    def queue_size(self):
-        return self.connection.size()
-
-    def delete_queue(self):
-        return self.connection.delete_queue()['msg']
-
-    def purge_queue(self):
-        return self.connection.clear()
-
-    def delete(self, task_id):
-        return self.connection.delete(task_id)['msg']
-
-    def fail(self, task_id):
-        self.delete(task_id)
-
-    def acknowledge(self, task_id):
-        return self.delete(task_id)
-
-    @staticmethod
-    def get_connection(list_key=Conf.PREFIX):
-        ironmq = IronMQ(name=None, **Conf.IRON_MQ)
-        return ironmq.queue(queue_name=list_key)