cerpus/pubsub

Client for RabbitMQ pub-sub

Maintainers

Details

github.com/cerpus/php-pubsub

Source

Issues

Installs: 8 697

Dependents: 1

Suggesters: 0

Security: 0

Stars: 0

Watchers: 3

Forks: 0

Open Issues: 0

v1.2.0 2023-12-01 14:23 UTC

Requires

Requires (Dev)

MIT 93b24c1b7eea00d910a1ac700afdbbf0d0261299

  • Max Moeschinger <max.moeschinger.woop@cerpus.com>
  • Emma Cecilie Hughes <emma.hughes.woop@cerpus.com>

This package is auto-updated.

Last update: 2024-10-30 01:42:58 UTC

README

Simple publish-subscribe for RabbitMQ and PHP.

Requirements

  • PHP 8.0, 8.1, or 8.2
  • The extensions required by php-amqplib

Installation

composer require cerpus/pubsub

Usage

use Cerpus\PubSub\Connection\ConnectionFactory;
use Cerpus\PubSub\PubSub;

$connectionFactory = new ConnectionFactory('localhost', 5672, 'guest', 'guest', '/');
$pubSub = new PubSub($connectionFactory->connect());

// publish your own messages
$pubSub->publish('some_other_topic', 'some data');

// listen for incoming messages
$pubSub->subscribe('subscriber_name', 'some_topic', function (string $data) {
    // do something with the data
    echo "$data\n";
});
$pubSub->listen();

Future scope

  • Support ext-amqp, queue-interop
  • Handle more exceptions from underlying libraries
  • Support configuring flags like auto-delete, etc.

License

This package is released under the MIT license. See the LICENSE file for more information.