Adds compat LifoQueue, as it's only available in Python >= 2.6. Closes #33. Thanks to fladi

1 files changed, 17 insertions, 0 deletions

diff --git a/kombu/utils/compat.py b/kombu/utils/compat.py
index 51736278..e9251b15 100644
--- a/kombu/utils/compat.py
+++ b/kombu/utils/compat.py
@@ -245,3 +245,20 @@ try:
     from collections import OrderedDict
 except ImportError:
     OrderedDict = CompatOrderedDict
+
+############## queue.LifoQueue ##############################################
+from Queue import Queue
+
+class LifoQueue(Queue):
+
+    def _init(self, maxsize):
+        self.queue = []
+
+    def _qsize(self, len=len):
+        return len(self.queue)
+
+    def _put(self, item):
+        self.queue.append(item)
+
+    def _get(self):
+        return self.queue.pop()