Log in
Model

QueueManagement

Magento\MysqlMq\Model\QueueManagement

What it does

This class manages MySQL-based message queue operations in Magento 2, handling the lifecycle of asynchronous messages.

Developers use it to add messages to queues, read messages for processing, change message statuses (new, in progress, complete, error), and clean up old messages based on configured lifetimes.

It's the core component for implementing queue-based asynchronous processing using MySQL as the queue storage backend.

Public Methods

  • addMessageToQueues()
  • addMessagesToQueues()
  • markMessagesForDelete()
  • readMessages()
  • pushToQueueForRetry()
  • changeStatus()