QueueFactory.php

Go to the documentation of this file.

<?php
namespace Magento\Deploy\Process;

use Magento\Framework\ObjectManagerInterface;
use Magento\Framework\Exception\LocalizedException;
use Magento\Framework\Phrase;

class QueueFactory
{
    private $objectManager;

    private $type;

    public function __construct(ObjectManagerInterface $objectManager, $type = Queue::class)
    {
        $this->objectManager = $objectManager;
        $this->type = $type;
    }

    public function create(array $arguments = [])
    {
        $queue = $this->objectManager->create($this->type, $arguments);
        if (!$queue instanceof Queue) {
            throw new LocalizedException(
                new Phrase("Wrong queue type specified.")
            );
        }
        return $queue;
    }
}