/
githubmirror
/
magento2
Обзор
Документация
Войти
/
githubmirror
/
magento2
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
2.4-develop
lib/internal/Magento/Framework/MessageQueue/MessageProcessorLoader.php
69 строк
2 KB
Alexandra Zota
ACP2E-4019: CE copyright updates for 2.4.9-beta1
22 окт 2025, 17:47
22 окт 2025, 17:47
1b769b7
Код
Авторство
О чём код?
<?php /** * Copyright 2018 Adobe * All Rights Reserved. */ namespace Magento\Framework\MessageQueue; /** * Loads message processor depending on the message type. */ class MessageProcessorLoader { /** * @var \Magento\Framework\MessageQueue\MessageProcessorInterface */ private $mergedMessageProcessor; /** * @var \Magento\Framework\MessageQueue\MessageProcessorInterface */ private $defaultMessageProcessor; /** * @param MessageProcessorInterface $mergedMessageProcessor * @param MessageProcessorInterface $defaultMessageProcessor */ public function __construct( MessageProcessorInterface $mergedMessageProcessor, MessageProcessorInterface $defaultMessageProcessor ) { $this->mergedMessageProcessor = $mergedMessageProcessor; $this->defaultMessageProcessor = $defaultMessageProcessor; } /** * Loads message processor depending on the message type. * * @param array $messages * @return MessageProcessorInterface */ public function load(array $messages) { $message = $this->getMergedMessage($messages); return ($message instanceof MergedMessageInterface) ? $this->mergedMessageProcessor : $this->defaultMessageProcessor; } /** * Get first message from the list of merged messages. * * @param array $messages * @return mixed|null */ private function getMergedMessage(array $messages) { $message = null; if ($messages) { $topicMessages = array_shift($messages); if ($topicMessages) { $message = array_shift($topicMessages); } } return $message; } }