README

Framework-agnostic PHP message broker facade for publishing the same message through one or more transports.

Installation

composer require jarir-ahmed/message-broker

Install the optional client library for each transport you want to use.

Usage

use JarirAhmed\MessageBroker\MessageBroker;

$broker = new MessageBroker(
    ['custom', 'rabbitmq'],
    [
        'rabbitmq' => [
            'host' => 'localhost',
            'user' => 'guest',
            'password' => 'guest',
        ],
    ]
);

$broker->connect();
$broker->publish('orders.created', json_encode(['id' => 123], JSON_THROW_ON_ERROR));
$broker->close();

Supported broker names are:

• activemq
• azureservicebus
• custom
• gcppubsub
• kafka
• mqtt
• nats
• rabbitmq
• redis
• sqs
• zeromq

The custom broker is in-memory and has no external dependencies, which makes it useful for tests and local development.