We use composer and cotya/magento-composer-installer plugin to install magento-enqueue extension.
To install libraries run the commands in the application root directory.
composer require "enqueue/magento2-enqueue:*@dev" "enqueue/amqp-ext"
php bin/magento setup:upgrade At this stage we have configure the Enqueue extension in Magento backend.
The config is here: Stores -> Configuration -> General -> Enqueue Message Queue.
Here's the example of Amqp transport that connects to RabbitMQ broker on localhost:
To send a message you have to take enqueue helper and call send method.
<?php
$objectManager = \Magento\Framework\App\ObjectManager::getInstance();
$enqueueManager = $objectManager->create('Enqueue\Enqueue\Model\EnqueueManager');
$enqueueManager->send('a_topic', 'aMessage');I assume you have acme Magento module properly created, configured and registered.
To consume messages you have to define a processor class first:
<?php
// app/code/Acme/Module/Helper/Async/Foo.php
namespace Acme\Module\Helper\Async;
use Interop\Queue\PsrContext;
use Interop\Queue\PsrMessage;
use Interop\Queue\PsrProcessor;
class Foo implements PsrProcessor
{
public function process(PsrMessage $message, PsrContext $context)
{
// do job
// $message->getBody() -> 'payload'
return self::ACK; // acknowledge message
// return self::REJECT; // reject message
// return self::REQUEUE; // requeue message
}
}than subscribe it to a topic or several topics:
<!-- app/etc/local.xml -->
<config>
<default>
<enqueue>
<processors>
<foo-processor>
<topic>a_topic</topic>
<helper>acme/async_foo</helper>
</foo-processor>
</processors>
</enqueue>
</default>
</config>and run message consume command:
$ php bin/magento enqueue:consume -vvv --setup-broker