Xervice\LogRabbitMq\LogRabbitMqFactory

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	createLogExchange()	0	8	1
A	createLogQueue()	0	7	1
A	createLogQueueBind()	0	8	1
A	getRabbitMqClient()	0	3	1

<?php


namespace Xervice\LogRabbitMq;


use DataProvider\RabbitMqExchangeDataProvider;
use DataProvider\RabbitMqQueueBindDataProvider;
use DataProvider\RabbitMqQueueDataProvider;
use Xervice\Core\Factory\AbstractFactory;
use Xervice\RabbitMQ\Core\ExchangeProvider;
use Xervice\RabbitMQ\RabbitMQClient;

/**
 * @method \Xervice\LogRabbitMq\LogRabbitMqConfig getConfig()
 */
class LogRabbitMqFactory extends AbstractFactory
{

    /**
     * @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\RabbitMQClient
     */
    public function getRabbitMqClient(): RabbitMQClient
    {
        return $this->getDependency(LogRabbitMqDependencyProvider::RABBITMQ_CLIENT);
    }
}