We changed our privacy policy. Read more.

Questions tagged [message-queue]

Questions related to Message Queue in Magento 2 EE

Filter by
Sorted by
Tagged with
4
votes
1answer
2k views

"Error while checking if topic is synchronous" on setup:upgrade

While upgrading a 2.2.8 database to 2.3.2 I got this error today: Schema post-updates: Module 'Magento_Store': ...
0
votes
1answer
20 views

How to clear queued email messages so they don't send

While moving from M1 to M2 a number of sales-related emails are generated and stack up in the queue. I don't want these messages to be sent to customers regarding "old" orders. How can I ...
23
votes
6answers
26k views

Consumer "async.operations.all" skipped as required connection "amqp" is not configured. Unknown connection name amqp

Since I upgraded from Magento 2.2.7 to Magento 2.3.1 I am getting this message in the system.log file: main.INFO: Consumer "async.operations.all" skipped as required connection "amqp" is not ...
0
votes
1answer
16 views

How to find the queue of CSV to export?

I'm running a Magento 2 Commerce and trying to export it via admin panel it didn't work, it seems like it's running forever in the background. How could I check the export queue and clean it? Is it ...
0
votes
1answer
21 views

Magento2: what is the purpose of having db_schema_whitelist.json?

I'm looking for some sort of explanation for the below topics but I'm not able to find the exact answers on the internet. What is the need for db_schema_whitelist.json? (I have read that this file ...
0
votes
2answers
272 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 ...
0
votes
0answers
33 views

Clear cron status message not in database or log files

I'm running Magento Enterprise 2.4.1 and I'm seeing a message on admin screens for more than a month that says "Update attributes for 3 selected products"; 1 item(s) have been scheduled for ...
1
vote
1answer
2k views

Bulk Operations Exception: Message queue topic "example.topic" is not configured

I am trying to implement Bulk Operations in Magento 2.3.1 using the docs here as a reference. When I call scheduleBulk on the BulkManagementInterface the operation is saved and can be viewed from the ...
0
votes
0answers
35 views

Magento messageQueue publish is failing

I am trying to create a messagequeue consumer to run a cron job manually with parameters I have defined configuration files (see below), and I can run s:up and s:d:c successfully, but when I go to use ...
1
vote
1answer
60 views

Observer for mass product attribute queues

I would like to do some extra custom actions after a product price is changed. I was thinking to use the catalog_product_save_after event when a mass price update is done from the Product Grid -> ...
0
votes
2answers
64 views

What is max_messages proper value for running message queue using cron job?

I'm using Magento 2.4.1, and this is my message queue configuration in app/etc/env.php 'queue' => [ 'consumers_wait_for_messages' => 0 ], 'cron_consumers_runner' => [ 'cron_run' => ...
0
votes
1answer
64 views

Run controller in background Magento 2.3

How can I run controller in background? I read about Message Queues and Deferred Actions, but it is hard for me to understand how it works and which should I use. For now it is implemented like this: ...
1
vote
2answers
62 views

Avoid getting old data from customerRegistry in queue runner

We have a Magento 2 Queue Job which loads a customer /** @var \Magento\Customer\Model\ResourceModel\CustomerRepository */ $this->customerRepository->getById($this->customerId)); Now we ...
0
votes
1answer
266 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' => [ '...
7
votes
1answer
394 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 ...
1
vote
0answers
652 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 below command sudo php bin/magento  queue:consumers:start custom.json.update Consumer works for ...
3
votes
2answers
1k 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' => '...
0
votes
0answers
36 views

Magento 2 Async WebAPI: Data in topic must be of type mixed. array given

I'm using magento v2.3.4 and created a Magento 2 rest webapi function like this: /** * POST for create brands api * @param mixed $data * @return array */ public function create($data); I usually ...
3
votes
0answers
83 views

consumers_wait_for_messages not adhered to

I'm trying to run my message queue consumer in a cronjob but the process never exits which means my cronjob never exits either. Looking at the docs https://devdocs.magento.com/guides/v2.3/config-guide/...
1
vote
1answer
695 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 ...
0
votes
1answer
232 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 ...
4
votes
1answer
2k 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 ...
3
votes
3answers
3k views

Magento 2.3.2 CE and Cron jobs, flock and RabbitMQ

Last few days I was chasing an interesting bug in production system running Magento 2.3.2 CE Where as per community recommendation I run cron jobs like this flock --timeout=0 /run/lock/...
1
vote
1answer
156 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?
0
votes
0answers
105 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 ...
4
votes
0answers
363 views

Is it possible to disable Magento Message Queues

It seems that Magento 2.3 introduced the concept of message queues where certain jobs like bulk product updates, exports and some sales rule functionality is now processed asynchronously via these ...
0
votes
1answer
781 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? ...
2
votes
2answers
3k views

How can I skip queue messages and display action happend message in magento2.3?

I am doing bulk update attribute from admin side in magento2. I am not getting message of 'attribute has been updated' something like as. I am getting below message which is attached in screen shot ....
1
vote
1answer
581 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/...
6
votes
1answer
1k views

Which core modules use RabbitMQ in Magento Open Source 2.3?

Starting with Magento 2.3.0, the Magento_Queue module for RabbitMQ becomes part of the Open Source edition. Source: https://community.magento.com/t5/Magento-DevBlog/Magento-2-Open-Source-has-a-new-...
1
vote
1answer
945 views

How to debug Magento 2.3 queue's consumers with Xdebug?

I'm working with a Magento 2 queue at the moment. To debug Magento 2 console scripts I normally just hit 'listen to external connections' in PHPstorm and execute the CLI script (i'm using Valet+ with ...
1
vote
0answers
67 views

How to requeue message queue if something happen wrong

I am implementing message queue for my system. I want to know that how can i requeue any queue if something goes wrong or suppose my api didnt give me response as i wish so i want to send that message ...
1
vote
1answer
503 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
1
vote
1answer
89 views

What is the use of the merger class in Magento Message queue?

Can someone kindly explain the use of the Merger class when using Magento Message queue framework? Also, why is there no default merger class ?
1
vote
0answers
49 views

Magento 2: How to display messages in cachable pages

As a part of my functionality, using below I'm dispatching a conditional error message. <event name="controller_action_predispatch"> <observer name="...
8
votes
3answers
3k views

Add RabbitMQ to existing Magento 2 EE installation

Is there a way to add RabbitMQ/AMQP setup to an existing M2 EE installation? All the docs seem to shout that it has to be done at install time but that seems a bit limiting. However, I can't find ...
7
votes
1answer
3k views

How to integrate RabbitMQ with Magento 2.2.* EE

The way of setting up magento queues in M2 EE 2.2.* is different from how it used to be in version prior to 2.2.*. The queue.xml is deprecated and there are 3 new configuration files queue_consumer....
0
votes
0answers
423 views

Is there any web interface for message queue MySQL adapter in Magento 2?

Is there any web interface for "message queue MySQL adapter" in Magento 2 ? I have searched that, but cannot find anything (But no result for searches does not mean it doesn't exist though) magento ...
10
votes
1answer
2k views

Message queue configuration changes in Magento 2 EE 2.1

I've been looking at the EE message queues functionality, but it seems like it is incomplete. Prior to 2.1 there was a reasonably functional implementation that allowed you to create a etc/queue.xml ...
1
vote
1answer
1k views

How can I queue all Magento2 transactional emails?

I know Magento2 Enterprise Edition has this functionality already built into it. At the moment I am using a basic SMTP module to send all the transactional emails on my website, however, the process ...