1 files changed, 10 insertions, 0 deletions
diff --git a/modules/system/system.module b/modules/system/system.module
index 98d1b2f00..861c3c51c 100644
--- a/modules/system/system.module
+++ b/modules/system/system.module
@@ -1587,6 +1587,16 @@ function system_cron() {
   foreach ($cache_tables as $table) {
     cache_clear_all(NULL, $table);
   }
+
+  // Reset expired items in the default queue implementation table. If that's
+  // not used, this will simply be a no-op.
+  db_update('queue')
+    ->fields(array(
+      'consumer_id' => 0,
+      'expire' => 0,
+    ))
+    ->condition('expire', REQUEST_TIME, '<')
+    ->execute();
 }
 
 /**