Questions tagged [rabbit-mq]

Questions related to RabbitMQ support in Magento 2 EE

Filter by
Sorted by
Tagged with
0 votes
0 answers
16 views

Do I benefit from RabbitMQ when I have no integrations?

I have a shop that has big purchase peaks every now and then. Server can become unresponsive at those times with even the biggest server available. The shop does not have any ERP integrations and many ...
Webninja's user avatar
  • 1,593
0 votes
0 answers
38 views

Send data from Magento to ERP using RabbitMQ

I need to integrate Magento 2 with Odoo ERP by sending new orders from the first platform to the last. Shortly, when an order is placed, I need to make it available to the ERP system that will ...
iupaem's user avatar
  • 51
0 votes
0 answers
15 views

How to use multiply AMQP RabbitMQ connections in custom module

I need connect in custom module to multiply RabbitMQ hosts. So how setup it? I tried something like this in app/etc/env.php 'queue' => [ 'amqp' => [ 'connections' => [ ...
user1422208's user avatar
0 votes
0 answers
140 views

Configuring RabbitMQ with Magento 2: Bulk Queue Pending

I am trying to integrate RabbitMQ with Magento 2 to access bulk endpoints Bitnami Magento ver. 2.4.6-p2 I have successfully set up RabbitMQ with my Magento 2 instance, and now bulk requests are being ...
Ikram Khan's user avatar
1 vote
1 answer
301 views

Magento 2 How to unlock the consumer

We are using Magento 2.4.5-p5 EE and RabbitMQ message broker. The exportProcessor consumer is not consuming messages from the queue automatically (cron job consumers_runner is running every minute), ...
Vishwanath Kharabe's user avatar
0 votes
1 answer
88 views

Updating products in bulk with async endpoint fails with error getProductFromLocalCache() must be of the type string, null given

I'm trying to update multiple items as a batch in Version 2.4.3-p1 $productUpdates = []; foreach ($updates as $magento_sku => $data) { $productUpdates[] = [ 'sku' => $...
user2029890's user avatar
-1 votes
1 answer
84 views

Can someone explain correct answer about this message queue question?

what is the correct answer in this question? An Architect is working to implement Adobe Commerce into a pre-built ecosystem in a company. Communication between different company domains uses event-...
Muhammad Hossain's user avatar
1 vote
0 answers
18 views

How to make a queue available for 3rd party systems to consume

I need to create a message queue in Magento and expose it to the 3rd-party system. As I understand, it is required to create communication.xml, queue_publisher.xml, and queue_topology.xml files - so ...
G0sha's user avatar
  • 11
1 vote
2 answers
1k views

Does Magento 2 launch all RabbitMQ consumers only by cron?

I am very surprised by the fact that I found that it seems that Magento 2 launches all RabbitMQ consumers only by cron. I expected to see RabbitMQ as a separate application that accepts tasks from PHP ...
Dmitriy Morozov's user avatar
1 vote
1 answer
284 views

AWS MQ with Magento 2.4 Open Source

Is it enough to update the env.php file queue section to setup AWS MQ (Rabbit MQ as the messaging broker - version 3.9.13) Magento 2 version is M2.4.5 Setup the cron. I have done the below change in ...
Yogita's user avatar
  • 784
0 votes
1 answer
419 views

Magento 2.4.5 Missing exchange field error after Upgrade

After upgrading from 2.4.4 to 2.4.5 I am seeing the following error in admin when I try and save a product : Missing exchange field for publisher product_action_attribute.update in connection config. ...
paj's user avatar
  • 5,799
2 votes
0 answers
463 views

Very slow async bulk import via RabbitMQ

I'm importing products using bulk Magento APIs and RabbitMQ. The problem is that the process is too slow and sometimes it seems that completely stucks. Magento version is 2.4.2 and RabbitMQ version is ...
myh34d's user avatar
  • 121
0 votes
1 answer
2k views

magento rabitMQ error: Broken pipe or closed connection

Fatal error: Uncaught PhpAmqpLib\Exception\AMQPConnectionClosedException: Broken pipe or closed connection in /var/www/html/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php:228 Stack ...
Hassan Ali Shahzad's user avatar
1 vote
1 answer
1k views

How to clean up RabbitMQ queue?

I don't know if there are jobs waiting to be executed in the RabbitMQ queue, how could I check it and clean up? Opening the var/ folder I see many export files, not finished.
Rafael Corrêa Gomes's user avatar
0 votes
1 answer
1k views

RabbitMQ doesn't have any queue, how to solve it?

I have RabbitMQ installed and configured, but when I run this command below I receive a message saying No items. python3 /usr/bin/rabbitmqadmin --host rabbitmq -u username -p ...
Rafael Corrêa Gomes's user avatar
0 votes
2 answers
3k views

The connection timed out after 3 sec while awaiting incoming data from bluk import apis

I'm getting following error during use of bulk async import apis. The connection timed out after 3 sec while awaiting incoming data I've followed the magento dev docs for using for bulk import (Api) *...
Amit Maurya's user avatar
  • 2,871
0 votes
1 answer
1k views

Connection between magento with RabbitMQ

How to ensure the connection between RabbitMQ and Magento 2. Please help me to sort out this. I have successfully configured the RabbitMQ with Magento 2, And I have configured the same in my AWS ...
Jaisa's user avatar
  • 2,606
0 votes
0 answers
33 views

Can we use RabbitMQ free with magento 2

Can we use RabbitMQ free with Magento 2? Can anybody help me?
Jaisa's user avatar
  • 2,606
0 votes
1 answer
204 views

Why my CSV import worked but didn't apply the changes?

I imported a CSV file with 5 products, the CSV is successfully validated and imported, however, when I went into one of the products that I imported, the update didn't have an effect. After one hour I ...
Rafael Corrêa Gomes's user avatar
0 votes
1 answer
733 views

multiple queue: consumers: start async.operations.all in parallel

I would like to know why asynchronous operations processes queue: consumers: start async.operations.all are started every 10 minutes.
aib.ts's user avatar
  • 11
2 votes
3 answers
273 views

RabbitMQ shared by live and staging installs using Magento 2?

Is it possible/recommended for 2 separate installs of M2 to share the same RabbitMQ install? Is there a way to separate their data like with Elastic Search where you define a separate prefix?
Rob Mangiafico's user avatar
1 vote
2 answers
3k views

Does the default Magento 2.4.2 Require RabbitMQ Asynchronous message queueing?

Does Magento 2.4.2 (2.4.x) open source REQUIRE asynchronous message queueing (and thus installation of RabbitMQ) by default? I was under the impression that 'asynchronous message queueing' is an ...
Ray's user avatar
  • 43
0 votes
1 answer
952 views

Magento 2. RabbitMQ Ack or Reject message

I'm wondering if it is possible to manually Ack or Reject message from the RabbitMQ within the Magento 2 consumer process? What is the default behavior?
Alex Yeremenko's user avatar
0 votes
1 answer
957 views

Magento 2.4 EE - Consumers or RabbitMQ Consumers are not working, it should work automatically after deployment

Summary of the issue Queue Consumers are not working, it should work automatically after deployment. Information on your environment Magento EE 2.4 , RabbitMQ 3.8, Composer version- 1.10.16 ...
Amit Singh's user avatar
2 votes
1 answer
2k views

Magento 2 Type Error occurred when creating object: Magento\Framework\MessageQueue\Consumer\Config\Data

I've gone through the Megento Message queue process. I learned and tried one sample module in my local. but while run the queue:consumers:list command I am facing the following error. In ...
senthil's user avatar
  • 1,729
1 vote
1 answer
1k views

Getting error while publish message to RabbitMQ

I am getting an error while publishing a message to RabbitMQ :The connection timed out after 3 sec while awaiting for incoming data. use Magento\Framework\MessageQueue\PublisherInterface; $this->...
Birjitsinh Zala's user avatar
0 votes
1 answer
1k views

RabbitMQ - Why I see only async.operations.all in queue list?

I'm a little bit frustrated with Magento 2 queue for RabbitMQ. I have setup RabbitMQ, my env.php has such lines 'queue' => [ 'consumers_wait_for_messages' => 1, 'amqp' => [ '...
freento's user avatar
  • 143
2 votes
0 answers
405 views

Slow async bulk import via RabbitMQ, no multiple threads?

I really hope someone can help me out here. We have setup a RabbitMQ and a Magento 2.3.4. RabbitMQ runs and get about 83k messages via an import by our external product management software. There are ...
Keenora Fluffball's user avatar
4 votes
2 answers
5k views

RabbitMQ and cron_consumers_runner

If you are running RabbitMQ in M 2.3/2.4 and have the env.php section set up for amqp: 'queue' => [ 'amqp' => [ 'host' => '127.0.0.1', 'port' => '5672', '...
Rob Mangiafico's user avatar
3 votes
2 answers
3k views

Magento 2 not spawning consumer processes i DB (RabbitMQ)

I have setup Magento 2.4 with RabbitMQ. You can see my configuration here. 'queue' => [ 'amqp' => [ 'host' => 'rabbitmq.host', 'port' => '53003', 'user' => '...
puntable's user avatar
  • 528
1 vote
1 answer
2k views

Magento 2.4 Message queue issue with Mass actions

We have install magento 2.4 successfully with Rabbitmq Server 3.8.8. All seems to work fine in server side. But in admin when we try to update product attributes with magento native process we have ...
G. G.'s user avatar
  • 1,132
2 votes
0 answers
1k views

fwrite(): send of 21 bytes failed with errno=32 Broken pipe

I am using custom RabbitMQ message queues in custom Magento 2 extension. When i run consumer using the following command: sudo php bin/magento  queue:consumers:start custom.json.update Consumer works ...
Pandurang Babar's user avatar
7 votes
1 answer
1k views

How to move Magento core queues to RabbitMQ?

Magento has some core queues like: catalog_product_removed_queue codegenerator export inventory.mass.update inventory.reservations.cleanup inventory.reservations.update inventory.source.items.cleanup ...
udogan's user avatar
  • 71
1 vote
1 answer
408 views

How to connect magento2 to RabbittMQ on AWS

I have two Ec2 instances in AWS, on one instance I have installed Magento 2 and on another ec2 instance, I have installed RabbitMQ. How can I connect Magento 2 with RabbitMQ? I have given public IP of ...
Hitesh Agrawal's user avatar
5 votes
1 answer
7k views

why message queue consumer never exiting when --max-messages specified?

I'm using Magento 2.3.4 with RabbitMQ configured in the env.php to process my message queues, I start consumer using: bin/magento queue:consumers:start ConsumerName --max-messages 1 But the consumer ...
Rafael Corrêa Gomes's user avatar
1 vote
0 answers
713 views

Redis causing issue with AMQP

We are developing a new site and have created some custom consumers for AMQP, however we are getting the error Error while checking if topic is synchronous during the setup:upgrade part of our ...
Hurricane's user avatar
3 votes
0 answers
2k views

Import product using async rest bulk API and RabbitMQ

We are working on a shop with about 7k products that are provided by several messy CSV. We decided to parse data from all these CSV and try to use async bulk api for import products, basically ...
Daniele Rovatti's user avatar
2 votes
1 answer
673 views

Why do I need RabbitMQ?

Magento 2 offers easy integration to RabbitMQ, but why and when do I need RabbitMQ installed in my store?
Rafael Corrêa Gomes's user avatar
0 votes
1 answer
1k views

How the message queues schedule works?

I just configured my message queues to run via RabbitMQ, but I don't know the schedule and frequency of these processes. How could I check the schedule and change the number of processes to be ...
Rafael Corrêa Gomes's user avatar
0 votes
0 answers
295 views

Price not updating on front end after API product update

I have an issue in that whenever I update a product price using the asynchronous endpoint POST http://base.test/rest/all/async/V1/products (running Rabbit MQ), the price does not change on the ...
Magento Moon's user avatar
0 votes
1 answer
2k views

Magento 2.3 CE: Remove/Disable RabbitMQ feature completely

Does anyone know any way to disable/remove RabbitMQ from Magento 2.3.3 as this involves queues like product_action_attribute.update , product_action_attribute.website.update and exportProcessor? ...
sandip's user avatar
  • 4,004
0 votes
1 answer
210 views

Issue with API bulk action using RabbitMQ

I'm using RabbitMQ with Magento Community 2.3.1 version to handle Bulk REST API actions to update products. That works fine. But sometimes, with same messages, one item of the bulk action is not ...
Jerome D.'s user avatar
0 votes
1 answer
177 views

Magento 2 What to update in existing CE to get RabbitMQ working

I have a few installations that slowly have been upgraded to 2.3.3 without RabbitMQ. Now I have added Rabbit but I am not sure I've covered all changes needed. The queue config is added in etc/env....
Sven's user avatar
  • 121
10 votes
1 answer
7k views

NOT_FOUND - no queue 'async.operations.all' in vhost '/' : RabitMQ : Magento 2.3 EE

I am integrating RabbitMQ with magento 2.3. EE , When I try to run cron It is giving me below error NOT_FOUND - no queue 'async.operations.all' in vhost '/' Can anyone help me on this.
Hitesh Agrawal's user avatar
1 vote
1 answer
1k views

Magento 2 - RabbitMQ Message has been rejected: Warning: Error while sending QUERY packet

I'm using RabbitMQ as message broker as publisher/subscriber, but sometimes I receive the following error: Message has been rejected: Warning: Error while sending QUERY packet. PID=5987 in /var/...
Mirko Rapisarda's user avatar
0 votes
1 answer
111 views

Which is the supported version of rabitmq for magento 2.3 ce?

I followed the official magento documentation and installed Rabitmq 3.5.6. However i was reading this document https://www.rabbitmq.com/which-erlang.html and i found that Rabitmq 3.5.6 version is ...
Ashar Riaz's user avatar
  • 1,035
1 vote
0 answers
1k views

Magento 2.3 EE Bulk Asynchronous API Operations using RabbitMQ

We are currently testing the Bulk Asynchronous API Operations in Magento 2.3 EE (clean installation) with RabbitMQ. The issue we are finding is whilst creating configurable and simple products. It ...
RDDWH's user avatar
  • 19
0 votes
1 answer
857 views

Magento 2 Commerce. Is there a cron that runs rabbitmq consumers?

When cron runs I see a log that informs me that queue consumers failed to start. Is there a cron that runs rabbitmq consumers?
vitoriodachef's user avatar
1 vote
1 answer
1k views

Bulk products using rest Api with Rabbitmq custom queue

I want to create custom module in magento 2.3 beta to track the publisher message and processing message in consumer
P Ramulu's user avatar
  • 187
1 vote
1 answer
1k views

Create a Bulk products using rest api with rabbitMq custom queue in magento 2.3 beta

How to publish message to rabbitmq and read message in consumer and create a bulk products in magento while running custom queue in rabbitmq. I want to create custom module in magento 2.3 beta to ...
P Ramulu's user avatar
  • 187