Solo Job QueueDatabase-Backed Job Queue for PHP

Leased claims with ownership tokens, a retry policy stored with every job, deadlines, and a worker daemon on Doctrine DBAL.

Get Started

View on GitHub

🔐

Leased Claims

Each attempt gets a random token and an expiring lease. Only the current attempt can complete, fail or renew its job.

🔁

Retries per Job

Attempts, backoff and deadline are stored with each job when it is enqueued, so no worker setting can change them later.

🗄️

Four Databases

MySQL, MariaDB, PostgreSQL and SQLite through Doctrine DBAL, with SKIP LOCKED claims and retried lock conflicts.

🧹

Maintenance

Abandoned attempts are recovered with each job's own policy, overdue jobs expire, and finished history is pruned in batches.

⚙️

Worker Daemon

One job at a time, graceful shutdown on SIGTERM and SIGINT, limits for jobs, runtime and memory, and timed maintenance.

🔭

Observable

PSR-3 logging with the exception under its key, listener events for metrics and tracing, typed records for inspection.

Quick Example

php

use Solo\JobQueue\JobQueue;
use Solo\JobQueue\Codec\ContainerJobCodec;
use Solo\JobQueue\Storage\{DbalJobStorage, Schema};
use Solo\JobQueue\Worker\Worker;

Schema::install($connection);

$queue = new JobQueue(
    storage: new DbalJobStorage($connection),
    codec: new ContainerJobCodec($container),
);

$queue->push(new SendEmailJob('user@example.com', 'Welcome'), 'email');

// In a long-running process: claim, run and acknowledge one job at a time.
(new Worker($queue, type: 'email'))->run();

Installation

bash

composer require solophp/job-queue

Requirements: PHP 8.3+, ext-mbstring, Doctrine DBAL 4, and MySQL 8+, MariaDB 10.6+, PostgreSQL or SQLite 3.35+