PHP-MVC/framework/Queue/Driver/DatabaseDriver.php

<?php

namespace Framework\Queue\Driver;

use Closure;
use Framework\Queue\Job;
use Opis\Closure\SerializableClosure;

class DatabaseDriver implements Driver
{
    public function push(Closure $closure, ...$params): int
    {
        $wrapper = new SerializableClosure($closure);

        $job = new Job();
        $job->closure = serialize($wrapper);
        $job->params = serialize($params);
        $job->attempts = 0;
        $job->save();

        return $job->id;
    }

    public function shift(): ?Job
    {
        $attempts = config('queue.database.attempts');

        return Job::where('attempts', '<', $attempts)
            ->where('is_complete', false)
            ->first();
    }
}