diff options
| author | Dries Buytaert <dries@buytaert.net> | 2009-10-14 10:59:15 +0000 |
|---|---|---|
| committer | Dries Buytaert <dries@buytaert.net> | 2009-10-14 10:59:15 +0000 |
| commit | 30fa81a763d5624437cb066d555ea1c1880de394 (patch) | |
| tree | 1b6a4ae80d654c5a73117487e73c53929e003b52 | |
| parent | a019a9ebb050883437e759cd96b5d32a717de318 (diff) | |
| download | brdo-30fa81a763d5624437cb066d555ea1c1880de394.tar.gz brdo-30fa81a763d5624437cb066d555ea1c1880de394.tar.bz2 | |
- Patch #602306 by David Strauss, Damien Tournoud: Fixed bug in the default queue implementation.
| -rw-r--r-- | modules/system/system.queue.inc | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/modules/system/system.queue.inc b/modules/system/system.queue.inc index c384f581d..3e2979be1 100644 --- a/modules/system/system.queue.inc +++ b/modules/system/system.queue.inc @@ -198,7 +198,7 @@ class SystemQueue implements DrupalQueueInterface { // until an item is successfully claimed or we are reasonably sure there // are no unclaimed items left. while (TRUE) { - $item = db_query_range('SELECT data, item_id FROM {queue} q WHERE name = :name ORDER BY created ASC', 0, 1, array(':name' => $this->name))->fetchObject(); + $item = db_query_range('SELECT data, item_id FROM {queue} q WHERE expire = 0 AND name = :name ORDER BY created ASC', 0, 1, array(':name' => $this->name))->fetchObject(); if ($item) { // Try to update the item. Only one thread can succeed in UPDATEing the // same row. We cannot rely on REQUEST_TIME because items might be |