- Patch #659710 by fgm: queue API was missing a releaseItem method.

1 files changed, 18 insertions, 0 deletions

diff --git a/modules/system/system.queue.inc b/modules/system/system.queue.inc
index be0c31e97..5174a0a65 100644
--- a/modules/system/system.queue.inc
+++ b/modules/system/system.queue.inc
@@ -136,6 +136,15 @@ interface DrupalQueueInterface {
   public function deleteItem($item);
 
   /**
+   * Release an item that the worker could not process, so another
+   * worker can come in and process it before the timeout expires.
+   *
+   * @param $item
+   * @return boolean
+   */
+  public function releaseItem($item);
+
+  /**
    * Create a queue.
    *
    * Called during installation and should be used to perform any necessary
@@ -216,6 +225,15 @@ class SystemQueue implements DrupalQueueInterface {
     }
   }
 
+  public function releaseItem($item) {
+    $update = db_update('queue')
+      ->fields(array(
+        'expire' => 0,
+      ))
+      ->condition('item_id', $item->item_id);
+      return $update->execute();
+  }
+
   public function deleteItem($item) {
     db_delete('queue')
       ->condition('item_id', $item->item_id)