12 ->load(
'topic_second.updated.use.just.in.tests',
'topic_name');
19 ->load(
'queue1',
Magento\MysqlMq\Model\Queue::KEY_NAME)
22 ->load(
'queue2',
Magento\MysqlMq\Model\Queue::KEY_NAME)
25 ->load(
'queue3',
Magento\MysqlMq\Model\Queue::KEY_NAME)
28 ->load(
'queue4',
Magento\MysqlMq\Model\Queue::KEY_NAME)
39 foreach (
$plan as $instruction) {
42 $messageStatus->setQueueId($instruction[1])
43 ->setMessageId($instruction[0])
44 ->setUpdatedAt($instruction[2])
45 ->setStatus($instruction[3])
const MESSAGE_STATUS_IN_PROGRESS
static getObjectManager()