Another place messages can disappear.

zedshaw · Mar 6, 2013 · 7b45586 · 7b45586
1 parent a8df85c
commit 7b45586
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lamson/queue.py b/lamson/queue.py
@@ -155,7 +155,10 @@ def get(self, key):
 
     def remove(self, key):
         """Removes the queue, but not returned."""
-        self.mbox.remove(key)
+        try:
+            self.mbox.remove(key)
+        except IOError:
+            logging.exception("Failed to remove message from queue.")
 
     def count(self):
         """Returns the number of messages in the queue."""