/
githubmirror
/
magento2
Обзор
Документация
Войти
/
githubmirror
/
magento2
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
2.4-develop
lib/internal/Magento/Framework/MessageQueue/QueueRepository.php
47 строк
1 KB
Dnyaneshwar Jambhulkar
AC-14558::Migration form RabbitMQ to Apache ActiveMQ
21 июл 2025, 18:35
21 июл 2025, 18:35
446a6f3
Код
Авторство
О чём код?
<?php /** * Copyright 2015 Adobe * All Rights Reserved. */ namespace Magento\Framework\MessageQueue; /** * Queue factory */ class QueueRepository { /** * @var QueueInterface[] */ private $queueInstances; /** * @var QueueFactoryInterface */ private $queueFactory; /** * @param QueueFactoryInterface $queueFactory */ public function __construct(QueueFactoryInterface $queueFactory) { $this->queueFactory = $queueFactory; } /** * Get queue instance by connection name and queue name. * * @param string $connectionName * @param string $queueName * @return QueueInterface * @throws \LogicException */ public function get($connectionName, $queueName): QueueInterface { if (!isset($this->queueInstances[$connectionName][$queueName])) { $queue = $this->queueFactory->create($queueName, $connectionName); $this->queueInstances[$connectionName][$queueName] = $queue; } return $this->queueInstances[$connectionName][$queueName]; } }