Werkspot \ MessageBus \ MessageQueue \ WerkspotMessageQueue
, (*1)
, (*2)
This is an adapter around Werkspot\MessageQueue, so Werkspot\MessageBus can use it and still be decoupled., (*3)
Usage
The MessageDispatcher is the entry point to the message bus. There are already a few middlewares provided with
this library, which you can find in src/Bus/DeliveryChain., (*4)
use Werkspot\MessageBus\MessageQueue\WerkspotMessageQueue\MessageQueueService;
use Werkspot\MessageQueue\MessageQueueService as WerkspotMessageQueueService;
$message = new AsynchronousMessage('payload', 'destination', ['metadata']);
$messageQueueService = new MessageQueueService(new WerkspotMessageQueueService(/* ... */));
$messageQueueService->enqueueMessage($message);
Installation
To install the library, run the command below and you will get the latest version:, (*5)
composer require werkspot/message-bus-werkspot-message-queue-adapter
Tests
To execute the tests run:, (*6)
make test
Coverage
To generate the test coverage run:, (*7)
make test_with_coverage
Code standards
To fix the code standards run:, (*8)
make cs-fix