Xervice\RabbitMQ\Core\ExchangeProvider

Complexity

Total Complexity

3

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

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\Core;


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

class ExchangeProvider implements ExchangeProviderInterface
{
    const TYPE_DIRECT = 'direct';
    const TYPE_FANOUT = 'fanout';
    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 string $name
     * @param string $type
     * @param bool $passive
     * @param bool $durable
     * @param bool $auto_delete
     * @param bool $internal
     * @param bool $nowait
     */
    public function declare(RabbitMqExchangeDataProvider $exchangeDataProvider): void

Possible parse error: non-abstract method defined as abstract

It is generally advisable to only define one property per statement.

    {
        $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()
        );
    }


}