Xervice\RabbitMQ\Business\Model\Core\ExchangeProvider

Complexity

Total Complexity

3

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

83.33%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	declare()	0	12	1
A	delete()	0	4	1

<?php


namespace Xervice\RabbitMQ\Business\Model\Core;


use DataProvider\RabbitMqExchangeDataProvider;
use PhpAmqpLib\Channel\AMQPChannel;

class ExchangeProvider implements ExchangeProviderInterface
{
    public const TYPE_DIRECT = 'direct';
    public const TYPE_FANOUT = 'fanout';
    public const TYPE_TOPIC = 'topic';

    /**
     * @var \PhpAmqpLib\Channel\AMQPChannel
     */
    private $channel;

    /**
     * Exchange constructor.
     *
     * @param \PhpAmqpLib\Channel\AMQPChannel $channel
     */
    public function __construct(AMQPChannel $channel)
    {
        $this->channel = $channel;
    }

    /**
     * @param \DataProvider\RabbitMqExchangeDataProvider $exchangeDataProvider
     */
    public function declare(RabbitMqExchangeDataProvider $exchangeDataProvider): void
    {
        $this->channel->exchange_declare(
            $exchangeDataProvider->getName(),
            $exchangeDataProvider->getType(),
            $exchangeDataProvider->getPassive(),
            $exchangeDataProvider->getDurable(),
            $exchangeDataProvider->getAutoDelete(),
            $exchangeDataProvider->getInternal(),
            $exchangeDataProvider->getNoWait(),
            $exchangeDataProvider->getArgument(),
            $exchangeDataProvider->getTicket()
        );
    }

    /**
     * @param \DataProvider\RabbitMqExchangeDataProvider $exchangeDataProvider
     */
    public function delete(RabbitMqExchangeDataProvider $exchangeDataProvider): void
    {
        $this->channel->exchange_delete(
            $exchangeDataProvider->getName()
        );
    }


}