DatabaseQueue::garbageCollection

public DatabaseQueue::garbageCollection()

public function garbageCollection() {
  try {
    // Clean up the queue for failed batches.
    $this->connection->delete(static::TABLE_NAME)
      ->condition('created', REQUEST_TIME - 864000, '<')
      ->condition('name', 'drupal_batch:%', 'LIKE')
      ->execute();

    // Reset expired items in the default queue implementation table. If that's
    // not used, this will simply be a no-op.
    $this->connection->update(static::TABLE_NAME)
      ->fields(array(
        'expire' => 0,
      ))
      ->condition('expire', 0, '<>')
      ->condition('expire', REQUEST_TIME, '<')
      ->execute();
  }
  catch (\Exception $e) {
    $this->catchException($e);
  }
}