function DatabaseQueue::releaseItem

File

core/lib/Drupal/Core/Queue/DatabaseQueue.php, line 158

Class

DatabaseQueue

Default queue implementation.

Namespace

Code

public function releaseItem($item) {
    try {
        $update = $this->connection
            ->update(static::TABLE_NAME)
            ->fields([
            'expire' => 0,
        ])
            ->condition('item_id', $item->item_id);
        return $update->execute();
    } catch (\Exception $e) {
        $this->catchException($e);
        // If the table doesn't exist we should consider the item released.
        return TRUE;
    }
}