monsieurbiz/amqp

Use the power of RabbitMQ in your e-commerce running with Magento 2.

MonsieurBiz AMQP

Use the power of RabbitMQ in your e-commerce running with Magento 2., _(*1)

Installation

With composer: composer require monsieurbiz/amqp., _(*2)

If you want to use delayed messages then you'll have to install the [Delayed Message Plugin][https://github.com/rabbitmq/rabbitmq-delayed-message-exchange] on your RabbitMQ instance., _(*3)

Create an exchange

magento monsieurbiz:amqp:exchange:create consume-me

With consume-me as exchange name., _(*4)

You can also use a delayed exchange:, _(*5)

magento monsieurbiz:amqp:exchange:create --delayed consume-me

You can create multiple exchange at once:, _(*6)

magento monsieurbiz:amqp:exchange:create first-exchange-name second-exchange-name

Consume a queue

You have to create a consumer/worker., _(*7)

Take a look at Console/Command/SampleCommand.php, it is a basic consumer., _(*8)

Send a message in an exchange

Considering that $amqp is an instance of \MonsieurBiz\Amqp\Helper\Amqp., _(*9)

Direct message

$amqp->sendMessage(
    'consume-me',
    ['my message content']
);

Delayed message

You need to install the Delayed Message Plugin on your RabbitMQ instance., _(*10)

$amqp->sendMessage(
    'consume-me',
    ['my message content'],
    [
        'application_headers' => new AMQPTable([
            'x-delay' => 5000 // 5 seconds of delay
        ]),
    ]
);

RPC

Considering that $rpc is an instance of \MonsieurBiz\Amqp\Helper\Rpc., _(*11)

Direct request

To send a request to the broker and get a response right away:, _(*12)

$response = $rpc->directRequest(
    'consume-me',
    ['my message content']
);

echo $response; // ["my message content"]

Batch messages

Before sending a batch, you should be aware on how RPC works., _(*13)

Don't forget to keep the correlation identifier of every request you make., _(*14)

$c1 = $rpc->request('consume-me', ['my first message']);
$c2 = $rpc->request('consume-me', ['my second message']);

$responses = $rpc->getResponses();

var_dump($responses[$c1]); // string(20) "["my first message"]"
var_dump($responses[$c2]); // string(21) "["my second message"]"

More you have consumers running faster you'll get the responses., _(*15)

LICENSE

(c) Monsieur Biz opensource@monsieurbiz.com, _(*16)

For the full copyright and license information, please view the LICENSE file that was distributed with this source code., _(*17)