Magento 2 Message Queue OS AMQP Broker Implementation

Renato

Last update: Jul 12, 2022

Related tags

Miscellaneous magento2-module-mq-amqp

Overview

Magento 2 Message Queue AMQP Backend

AMQP message queue backend implementation for Rcason_Mq.

Installation

Require the module via Composer

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

Enable the module

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

Configuration

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

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

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>

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

You might also like...

A lightweight queue based on Redis Stream for webman plugin.

workbunny/webman-rqueue 🐇 A lightweight queue based on Redis Stream for webman plugin. 🐇 A lightweight queue based on Redis Stream for webman plugin

10 Dec 12, 2022

PHP library for Disque, an in-memory, distributed job queue

disque-php A PHP library for the very promising disque distributed job queue. Features: Support for both PHP (5.5+) and HHVM No dependencies: Fast con

132 Oct 19, 2022

PHP Web User Queue designed to run on shared hosting

WebUserQueue Introduction This is a web user queueing system written in PHP with a MySQL backend designed to run on shared hosting. It was designed to

0 Aug 13, 2022

Fully covered with tests, documented by Swagger and dockerized API based on enterprise-level framework with optional queue worker.

symfony-api Fully covered with tests, documented by Swagger and dockerized API based on enterprise-level framework with optional queue worker. ⚙️ Depl

1 Nov 20, 2022

PHP Lightweight Message Bus supporting CQRS.

Prooph Service Bus PHP 7.1+ lightweight message bus supporting CQRS and Micro Services Important This library will receive support until December 31,

440 Nov 20, 2022

Xenon\LaravelBDSms is a sms gateway package for sending text message to Bangladeshi mobile numbers using several gateways like sslcommerz, greenweb, dianahost,metronet in Laravel framework

Xenon\LaravelBDSms is a sms gateway package for sending text message to Bangladeshi mobile numbers using several gateways for Laravel. You should use

95 Jan 3, 2023

Get dialogflow fullfilment message in PHP

Comments

Invalid Schema error
On Magento CE 2.1.7 and 2.1.9, after bin/magento setup:upgrade the following error is generated in CLI.

[Exception] Warning: DOMDocument::schemaValidate(): Invalid Schema in /vendor/magento/framework/Config/Dom.php on line 311

Running setup:db-schema:upgrade and magento setup:db-data:upgrade, or even manually fix the schema version in db don't cause the error to disappear in CLI.
opened by alessandromassobrio 5