PHPackages                             renatocason/magento2-module-mq - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. renatocason/magento2-module-mq

ActiveMagento2-module[Queues & Workers](/categories/queues)

renatocason/magento2-module-mq
==============================

Magento 2 Message Queue OS Module

1.1.4(5y ago)3515.2k17[4 issues](https://github.com/renatocason/magento2-module-mq/issues)[1 PRs](https://github.com/renatocason/magento2-module-mq/pulls)4OSL-3.0PHPPHP ~7.1.0|~7.2.0|~7.3.0CI failing

Since Jun 8Pushed 5y ago8 watchersCompare

[ Source](https://github.com/renatocason/magento2-module-mq)[ Packagist](https://packagist.org/packages/renatocason/magento2-module-mq)[ RSS](/packages/renatocason-magento2-module-mq/feed)WikiDiscussions master Synced 3w ago

READMEChangelog (10)Dependencies (5)Versions (15)Used By (4)

Magento 2 Message Queue Module
==============================

[](#magento-2-message-queue-module)

Lightweight implementation of message queue for Magento 2 Community Edition.

[![Build Status](https://camo.githubusercontent.com/be949d19c455b91695f0d5aa315eb370db2429fa4388f0b4e8b405d8619f02c0/68747470733a2f2f7472617669732d63692e6f72672f72656e61746f6361736f6e2f6d6167656e746f322d6d6f64756c652d6d712e7376673f6272616e63683d6d6173746572)](https://travis-ci.org/renatocason/magento2-module-mq)[![Coverage Status](https://camo.githubusercontent.com/5270db597fde599fca6982012213ceec3ce07b12415a3b266f5ae0b07ec42acd/68747470733a2f2f636f766572616c6c732e696f2f7265706f732f6769746875622f72656e61746f6361736f6e2f6d6167656e746f322d6d6f64756c652d6d712f62616467652e7376673f6272616e63683d6d6173746572)](https://coveralls.io/github/renatocason/magento2-module-mq?branch=master)[![Latest Stable Version](https://camo.githubusercontent.com/42749a144575ce611a8b2e1d33e1c86ca708ee990995d39a03f262607d879b05/68747470733a2f2f706f7365722e707567782e6f72672f72656e61746f6361736f6e2f6d6167656e746f322d6d6f64756c652d6d712f762f737461626c65)](https://packagist.org/packages/renatocason/magento2-module-mq)[![Latest Unstable Version](https://camo.githubusercontent.com/cca93f4e77cbc5256f56ac3c927a648fa94f89193acb6285a40e6d6749d9555e/68747470733a2f2f706f7365722e707567782e6f72672f72656e61746f6361736f6e2f6d6167656e746f322d6d6f64756c652d6d712f762f756e737461626c65)](https://packagist.org/packages/renatocason/magento2-module-mq)[![Total Downloads](https://camo.githubusercontent.com/ad01d67e162a87a686a305ddbce8f41f9959885126501add7c3c9e0d396b887c/68747470733a2f2f706f7365722e707567782e6f72672f72656e61746f6361736f6e2f6d6167656e746f322d6d6f64756c652d6d712f646f776e6c6f616473)](https://packagist.org/packages/renatocason/magento2-module-mq)[![License](https://camo.githubusercontent.com/6365590de1c022bf19191258270b96a13c950558f44c98d83a9b3876a543ba5f/68747470733a2f2f706f7365722e707567782e6f72672f72656e61746f6361736f6e2f6d6167656e746f322d6d6f64756c652d6d712f6c6963656e7365)](https://packagist.org/packages/renatocason/magento2-module-mq)

System requirements
-------------------

[](#system-requirements)

This extension supports the following versions of Magento:

- Community Edition (CE) versions 2.1.x
- Community Edition (CE) versions 2.2.x
- Community Edition (CE) versions 2.3.x

Installation
------------

[](#installation)

1. Require the module via Composer

```
$ composer require renatocason/magento2-module-mq
```

2. Enable the module

```
$ bin/magento module:enable Rcason_Mq
$ bin/magento setup:upgrade
```

3. Install a message queue backend extension of your choice (see *Message queue backends* section)
4. Configure your queue(s) and implement your consumer(s) (see *Implementation* section)
5. Check the correct configuration of your queue(s)

```
$ bin/magento ce_mq:queues:list
```

6. Run your consumer(s)

```
$ bin/magento ce_mq:consumers:start product.updates
```

Message queue backends
----------------------

[](#message-queue-backends)

This module does not include any message queue backend implementation. You will have to chose and install one of the following modules (or implement your own) in order to get your message queues working:

- [MqMysql](https://github.com/renatocason/magento2-module-mq-mysql) - Stores messages in the database
- [MqAmqp](https://github.com/renatocason/magento2-module-mq-amqp) - Integrates any AMQP queue manager (i.e. RabbitMQ)
- Amazon SQS - Integrates Amazon SQS as a queue manager (work in progress)

Implementation
--------------

[](#implementation)

A simple example can be found [here](https://github.com/renatocason/magento2-module-mq-example).

1. Configure queue(s) in your module's *etc/m2\_mq.xml* file

```

```

2. Require the publisher in the classes you need it

```
/**
 * @param \Rcason\Mq\Api\PublisherInterface $publisher
 */
public function __construct(
    \Rcason\Mq\Api\PublisherInterface $publisher
) {
    $this->publisher = $publisher;
}
```

3. Use it to queue messages

```
$this->publisher->publish('product.updates', $productId);
```

4. Implement your consumer(s)

```
class ExampleConsumer implements \Rcason\Mq\Api\ConsumerInterface
{
    /**
     * {@inheritdoc}
     */
    public function process($productId)
    {
        // Your code here
    }
}
```

Authors, contributors and maintainers
-------------------------------------

[](#authors-contributors-and-maintainers)

Author:

- [Renato Cason](https://github.com/renatocason)

Contributions:

- [grafikchaos](https://github.com/grafikchaos)
- [jonathan-martz](https://github.com/jonathan-martz)
- [antoninobonumore](https://github.com/antoninobonumore)
- For a full list of contributors visit [Magento 2 Message Queue Module on GitHub](https://github.com/renatocason/magento2-module-mq/graphs/contributors)

License
-------

[](#license)

Licensed under the Open Software License version 3.0

###  Health Score

38

—

LowBetter than 83% of packages

Maintenance18

Infrequent updates — may be unmaintained

Popularity34

Limited adoption so far

Community22

Small or concentrated contributor base

Maturity66

Established project with proven stability

 Bus Factor1

Top contributor holds 95.8% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~113 days

Recently: every ~172 days

Total

12

Last Release

2057d ago

Major Versions

0.1.2 → 1.0.02018-07-03

PHP version history (5 changes)0.1.0PHP ~5.6.5|~7.0.0

0.1.1PHP ~7.0.0

1.0.0PHP ~7.0.0|~7.1.0

1.1.0PHP ~7.1.0|~7.2.0

1.1.1PHP ~7.1.0|~7.2.0|~7.3.0

### Community

Maintainers

![](https://www.gravatar.com/avatar/73ef335b0adb3d09260814815de5236712b71ecc71d16775922f484358e7c345?d=identicon)[renatocason](/maintainers/renatocason)

---

Top Contributors

[![renatocason](https://avatars.githubusercontent.com/u/7037728?v=4)](https://github.com/renatocason "renatocason (23 commits)")[![antoninobonumore](https://avatars.githubusercontent.com/u/1431493?v=4)](https://github.com/antoninobonumore "antoninobonumore (1 commits)")

###  Code Quality

TestsPHPUnit

Code StylePHP\_CodeSniffer

### Embed Badge

![Health badge](/badges/renatocason-magento2-module-mq/health.svg)

```
[![Health](https://phpackages.com/badges/renatocason-magento2-module-mq/health.svg)](https://phpackages.com/packages/renatocason-magento2-module-mq)
```

###  Alternatives

[loki/magento2-components

Core module for defining Alpine.js components with advanced AJAX features

1010.0k22](/packages/loki-magento2-components)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)