A newer version of this documentation is available: View the Latest Version

Consumer

To be able to process steps in a message queue, a Magento consumer is required.

  • The Magento consumer handles the communication between the Magento system and the configured message queue.

  • The enqueued steps in the MQ are retrieved by the runner(s) and processed via the executor logic.

CLI Command

e.g. Rabbit-MQ

bin/magento queue:consumer:start pipeline.runner.amqp

MySQL-MQ

bin/magento queue:consumer:start pipeline.runner.db

Example

Processing by an AMQP PipelineRunner / Magento Consumer.

bin/magento pipeline:status

Output

bin/magento pipeline:status
output consumer pipeline status
bin/magento queue:consumer:start pipeline.runner.amqp
bin/magento pipeline:status
output consumer pipeline start pipeline runner amqp

The first step for the enqueued pipeline 21, is now passed to the message queue (Rabbit-MQ) for processing.