Xervice\RabbitMQ\Business\Model\Core\QueueProvider

Complexity

Total Complexity

4

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

88.46%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	4	1
A	declare()	0	11	1
A	__construct()	0	3	1
A	bind()	0	9	1

<?php


namespace Xervice\RabbitMQ\Business\Model\Core;


use DataProvider\RabbitMqQueueBindDataProvider;
use DataProvider\RabbitMqQueueDataProvider;
use PhpAmqpLib\Channel\AMQPChannel;

class QueueProvider implements QueueProviderInterface
{
    /**
     * @var \PhpAmqpLib\Channel\AMQPChannel
     */
    private $channel;

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

    /**
     * @param \DataProvider\RabbitMqQueueDataProvider $queueDataProvider
     */
    public function declare(RabbitMqQueueDataProvider $queueDataProvider): void
    {
        $this->channel->queue_declare(
            $queueDataProvider->getName(),
            $queueDataProvider->getPassive(),
            $queueDataProvider->getDurable(),
            $queueDataProvider->getExclusive(),
            $queueDataProvider->getAutoDelete(),
            $queueDataProvider->getNoWait(),
            $queueDataProvider->getArgument(),
            $queueDataProvider->getTicket()
        );
    }


    /**
     * @param \DataProvider\RabbitMqQueueBindDataProvider $bindDataProvider
     */
    public function bind(RabbitMqQueueBindDataProvider $bindDataProvider): void
    {
        $this->channel->queue_bind(
            $bindDataProvider->getQueue()->getName(),
            $bindDataProvider->getExchange()->getName(),
            $bindDataProvider->getRoutingKey(),
            $bindDataProvider->getNoWait(),
            $bindDataProvider->getArgument(),
            $bindDataProvider->getTicket()
        );
    }

    /**
     * @param \DataProvider\RabbitMqQueueDataProvider $queueDataProvider
     */
    public function delete(RabbitMqQueueDataProvider $queueDataProvider): void
    {
        $this->channel->queue_delete(
            $queueDataProvider->getName()
        );
    }


}