summaryrefslogtreecommitdiff
path: root/classes
diff options
context:
space:
mode:
authorBrion Vibber <brion@pobox.com>2010-06-26 15:07:32 -0400
committerBrion Vibber <brion@pobox.com>2010-06-26 15:07:32 -0400
commitf0c5e7eca3842411d4e3ee6efb3fd6ac0ad85f4a (patch)
tree1cb482ff35e53974eb6fb6c738e99841af82f7a5 /classes
parent9eb5a976b03fae6bd1e1fce6abfe4a6c7964d1ae (diff)
Fix for bug #2382: releasing claim on failed queue item works again with DB-based queues.
Warning: DB-based queue doesn't currently implement discarding of items after a retry limit. Failed items will be retried until they succeed.
Diffstat (limited to 'classes')
-rw-r--r--classes/Queue_item.php13
1 files changed, 13 insertions, 0 deletions
diff --git a/classes/Queue_item.php b/classes/Queue_item.php
index f83c2cef1..c7e17be6e 100644
--- a/classes/Queue_item.php
+++ b/classes/Queue_item.php
@@ -64,4 +64,17 @@ class Queue_item extends Memcached_DataObject
$qi = null;
return null;
}
+
+ /**
+ * Release a claimed item.
+ */
+ function releaseCLaim()
+ {
+ // DB_DataObject doesn't let us save nulls right now
+ $sql = sprintf("UPDATE queue_item SET claimed=NULL WHERE id=%d", $this->id);
+ $this->query($sql);
+
+ $this->claimed = null;
+ $this->encache();
+ }
}