marko/queue-rabbitmq

RabbitMQ queue driver for Marko Framework

0.0.1 2026-03-25 17:53 UTC

Requires

• php: ^8.5
• marko/core: 0.0.1
• marko/queue: 0.0.1
• php-amqplib/php-amqplib: ^3.0

Requires (Dev)

• pestphp/pest: ^4.0

MIT

README

RabbitMQ queue driver--processes jobs through AMQP with persistent messages, exchange routing, and delayed delivery.

Installation

composer require marko/queue-rabbitmq

Quick Example

use Marko\Queue\QueueInterface;

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

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

    // Delay by 30 seconds using dead-letter exchange
    $this->queue->later(30, new SendReceipt($orderId));
}

Documentation

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