Xervice\LogRabbitMq\Business\LogRabbitMqBusinessFactory

Complexity

Total Complexity

4

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	createLogQueueBind()	0	8	1
A	getRabbitMqFacade()	0	3	1
A	createLogExchange()	0	8	1
A	createLogQueue()	0	7	1

<?php


namespace Xervice\LogRabbitMq\Business;


use DataProvider\RabbitMqExchangeDataProvider;
use DataProvider\RabbitMqQueueBindDataProvider;
use DataProvider\RabbitMqQueueDataProvider;
use Xervice\Core\Business\Model\Factory\AbstractBusinessFactory;
use Xervice\LogRabbitMq\LogRabbitMqDependencyProvider;
use Xervice\RabbitMQ\Business\Model\Core\ExchangeProvider;
use Xervice\RabbitMQ\Business\RabbitMQFacade;

/**
 * @method \Xervice\LogRabbitMq\LogRabbitMqConfig getConfig()
 */
class LogRabbitMqBusinessFactory extends AbstractBusinessFactory
{

    /**
     * @return \DataProvider\RabbitMqQueueBindDataProvider
     */
    public function createLogQueueBind(): RabbitMqQueueBindDataProvider
    {
        return (new RabbitMqQueueBindDataProvider())
            ->setExchange(
                $this->createLogExchange()
            )
            ->setQueue(
                $this->createLogQueue()
            );
    }

    /**
     * @return \DataProvider\RabbitMqQueueDataProvider
     */
    public function createLogQueue(): RabbitMqQueueDataProvider
    {
        return (new RabbitMqQueueDataProvider())
            ->setName(
                $this->getConfig()->getQueueName()
            )
            ->setAutoDelete(false);
    }

    /**
     * @return \DataProvider\RabbitMqExchangeDataProvider
     */
    public function createLogExchange(): RabbitMqExchangeDataProvider
    {
        return (new RabbitMqExchangeDataProvider())
            ->setName(
                $this->getConfig()->getExchangeName()
            )
            ->setType(ExchangeProvider::TYPE_FANOUT)
            ->setAutoDelete(false);
    }

    /**
     * @return \Xervice\RabbitMQ\Business\RabbitMQFacade
     */
    public function getRabbitMqFacade(): RabbitMQFacade
    {
        return $this->getDependency(LogRabbitMqDependencyProvider::RABBITMQ_FACADE);
    }
}