marko/queue-database

Database queue driver — stores and processes jobs in SQL tables with transaction-safe polling and failed job persistence.

Installation

composer require marko/queue-database

Quick Example

use Marko\Queue\QueueInterface;

public function __construct(
    private readonly QueueInterface $queue,
) {}

public function enqueue(): void
{
    $this->queue->push(new ProcessOrder($orderId));

    // Delay by 5 minutes
    $this->queue->later(300, new SendFollowUp($orderId));
}

Documentation

Full usage, API reference, and examples: marko/queue-database