public function AcquiaPurgeQueueSmart::claimItem in Acquia Purge 7

SystemQueue::claimItem() doesn't included expired items in its query which means that it essentially breaks its own interface promise. Therefore we overload the implementation with one that does do this accurately. This should however flow back to core, which I'm doing as part of my D8 work.

Overrides AcquiaPurgeQueueEfficient::claimItem

File

lib/queue/AcquiaPurgeQueueSmart.php, line 66

Contains SmartQueue.

Class

AcquiaPurgeQueueSmart

Efficient query bundling database queue that disregards expired queue items.

Code

public function claimItem($lease_time = 30) {
  $this
    ->expireQueueItems();
  return parent::claimItem($lease_time);
}