Magento 2 Message Queue MySQL Backend

MySQL message queue backend implementation for Rcason_Mq.

Installation

1. Require the module via Composer

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

2. Enable the module

$ bin/magento module:enable Rcason_MqMysql
$ bin/magento setup:upgrade

Configuration

1. Configure the Mq module as explained here
2. Specify mysql as broker when configuring a queue in your module's etc/ce_mq.xml file

<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:module:Rcason_Mq:etc/ce_mq.xsd">
    <ceQueue name="product.updates" broker="mysql"
        messageSchema="int"
        consumerInterface="Rcason\MqExample\Model\ExampleConsumer"/>
</config>

Authors, contributors and maintainers

Author:

• Renato Cason

License

Licensed under the Open Software License version 3.0