webit/message-bus

1.0.0 2018-01-05 06:14 UTC

Requires

• php: >=7.0

Requires (Dev)

• phpunit/phpunit: ^6.0
• psr/log: ^1.0

Suggests

• psr/log: To use logging publisher, consumer and exception handlers.

MIT

• Daniel Bojdo

• message queue
• message bus

README

The library provides an abstraction to publish / consume messages to / from message bus.

Installation

composer require webit/message-bus ^1.0.0

Concepts introduction

Message

Message is just simple container to be published by Publisher and consumed by Consumer.

$message = new Message('message-type', json_encode(['some' => 'data to be sent']));

Message type is required to recognise what sort of message is sent and helps to understand how it should be handled. Message content is a message itself. It can be any string (not necessarily json).

Publisher and Consumer

Publisher publishes a message (using underlying infrastructure) but Consumer awaiting the Message to process it.

Infrastructure is to be provided by a separate package. It should provide "webit/message-bus-infrastructure:^1.0.0" Composer Virtual Package.

Tests

./vendor/bin/phpunit