Lizard Media MessageQueue

A module extending functionalities from magento/framework-message-queue component.

custom implementation of Magento\Framework\MessageQueue\ConsumerInterface making possible injection of envelope callback, which allows to introduce custom message consumption easily without copy-paste of whole class
a few implementations of LizardMedia\MessageQueue\Queue\Consumer\EnvelopeCallback\EnvelopeCallbackInterface, each handling message in its specific way, including x-death parameters support

Getting Started

These instructions will get you a copy of the project up and running on your local machine for development and testing purposes.

Simply run

composer require lizardmedia/module-message-queue

Download a ZIP version of the module and unpack it into your project into

app/code/LizardMedia/MessageQueue

If you use ZIP file you will need to install all dependencies of the module manually

Run this command

bin/magento module:enable LizardMedia_MessageQueue
bin/magento setup:upgrade

To make poison pill stop your consumers you have to run them with param --max-messages.

Please read CONTRIBUTING.md for details on our code of conduct, and the process for submitting pull requests to us.

We use SemVer for versioning. For the versions available, see the tags on this repository.

See also the list of contributors who participated in this project.

This project is licensed under the MIT License - see the LICENSE.md file for details