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()