Changes for core/lib/Drupal/Core/Queue/DatabaseQueue.php: 1 added line, 1 removed line.
Original line number
Diff line number
Diff line
@@ -75,7 +75,7 @@ public function claimItem($lease_time = 30) {
// until an item is successfully claimed or we are reasonably sure there
// are no unclaimed items left.
while(TRUE){
$item=$this->connection->queryRange('SELECT data, created, item_id FROM {queue} q WHERE expire = 0 AND name = :name ORDER BY created ASC',0,1,array(':name'=>$this->name))->fetchObject();
$item=$this->connection->queryRange('SELECT data, created, item_id FROM {queue} q WHERE expire = 0 AND name = :name ORDER BY created, item_id 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