renatocason/magento2-module-mq-amqp

Magento 2 Message Queue OS AMQP Broker Implementation

1.1.3 2020-11-07 19:01 UTC

Requires

• php: ~7.1.0|~7.2.0|~7.3.0
• magento/framework: 100.1.*|101.0.*|102.0.*
• php-amqplib/php-amqplib: ~2.7.3|~2.8.1
• renatocason/magento2-module-mq: ~1.1.0

Requires (Dev)

• php-coveralls/php-coveralls: ~2.1.0
• phpmd/phpmd: @stable
• phpunit/phpunit: ~6.5.13
• squizlabs/php_codesniffer: 3.3.1

OSL-3.0

README

AMQP message queue backend implementation for Rcason_Mq.

Installation

1. Require the module via Composer

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

1. Enable the module

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

Configuration

1. Configure the Mq module as explained here
2. Configure the AMQP connection in your app/etc/env.php file

  'ce_mq' => [
      'amqp' => [
          'host' => 'localhost',
          'port' => 5672,
          'username' => 'guest',
          'password' => 'guest',
          'virtualhost' => '/',
      ],
  ],

1. Specify amqp 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="amqp"
        messageSchema="int"
        consumerInterface="Rcason\MqExample\Model\ExampleConsumer"/>
</config>

1. Run the setup upgrade command each time you edit your queues configuration, as they are applied to the queue manager on a recurring upgrade script

$ bin/magento setup:upgrade

Authors, contributors and maintainers

Author:

• Renato Cason

License

Licensed under the Open Software License version 3.0