ext-pcntl: Required for queue:work job timeouts and graceful SIGTERM/SIGINT shutdown
marko/cache: Atomic locks for UniqueJobInterface jobs and the cache restart signal (queue.restart_signal_driver = cache); pair it with marko/cache-redis so locks and restarts are shared by every server

Provides

None

Conflicts

None

Replaces

None

MIT 9451a3a8ca43ba5806b983336b38b57abe08a2f6

Published on Packagist.org on 2026-11-03 19:18 UTC

This package is auto-updated.

Last update: 2026-11-03 19:19:09 UTC

README

Queue interfaces and worker infrastructure -- defines how jobs are dispatched and processed, not which backend stores them.

Installation

composer require marko/queue

Note: You also need a driver package. See marko/queue-sync, marko/queue-database, or marko/queue-rabbitmq.

Quick Example

use Marko\Queue\Job;
use Marko\Queue\QueueInterface;

class SendWelcomeEmail extends Job
{
    public function __construct(
        private readonly string $email,
    ) {}

    public function handle(): void
    {
        // Send the email...
    }
}

// Dispatch via QueueInterface
$queue->push(new SendWelcomeEmail('user@example.com'));

Documentation

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