lizardmedia / module-message-queue
Module extending message queue component
Installs: 2 688
Dependents: 1
Suggesters: 0
Security: 0
Stars: 2
Watchers: 2
Forks: 1
Open Issues: 0
Type:magento2-module
Requires
- php: ~7.3.0||~7.4.0
- magento/framework: 102.0.*||103.0.*
- magento/framework-message-queue: 100.3.*||100.4.*
This package is auto-updated.
Last update: 2024-11-29 06:22:19 UTC
README
A module extending functionalities from magento/framework-message-queue
component.
Features
- 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, includingx-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.
Prerequisites
- Magento 2.3/2.4
- PHP 7.3/7.4
- RabbitMQ 3.8.*
- Apply our patches for Magento Message Queue features.
Installing
Download the module
Using composer (suggested)
Simply run
composer require lizardmedia/module-message-queue
Downloading ZIP
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
Install the module
Run this command
bin/magento module:enable LizardMedia_MessageQueue
bin/magento setup:upgrade
Usage
To make poison pill stop your consumers you have to run them with param --max-messages
.
Contributing
Please read CONTRIBUTING.md for details on our code of conduct, and the process for submitting pull requests to us.
Versioning
We use SemVer for versioning. For the versions available, see the tags on this repository.
Authors
- Bartosz Kubicki - Initial work, fixes & maintenance - Lizard Media
See also the list of contributors who participated in this project.
License
This project is licensed under the MIT License - see the LICENSE.md file for details