bkubicki / rabbitmq-playground

1.0 2026-10-05 22:33 UTC

Requires

• php: >=8.1
• bkubicki/message-queue: ^1.1
• magento/framework: 102.0.*||103.0.*
• magento/framework-message-queue: 100.3.*||100.4.*

MIT

Published on Packagist.org on 2026-10-05 23:03 UTC

README

A module shows how more advanced topologies could be built, using DLX and message-ttl. Module shows example of topology with error fallback and retry mechanism. Additionally for entity.confirm and entity.cancel topics consumption of messages are delayed.

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.4.7+ (tested against 2.4.8)
• PHP 8.1/8.2/8.3
• RabbitMQ 3.8+ (tested against 4.1)
• No patches required. bartoszkubicki/magento2-mq-patches previously listed here is now archived — the Magento Message Queue bugs it addressed were fixed upstream in Magento core (see that repo's README for details on which core version fixed each one).

Installing

Download the module

Using composer (suggested)

Simply run

composer require bkubicki/rabbitmq-playground

This module depends on bkubicki/message-queue, which composer will resolve automatically.

Downloading ZIP

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

app/code/BKubicki/RabbitMqPlayground

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 BKubicki_RabbitMqPlayground
bin/magento setup:upgrade

Usage

Just install module and investigate topology created. Play around by publishing messages (take a look at console commands) and observe how messages are handled. Every consumer handler has a sleep function inside to make sure that message processing is visible in rabbitmq admin panel messages chart. Change consumers (Failure / Success in queue_consumer.xml to test different situations. Topology created by the module should look like on the graph

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 - bartoszkubicki

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