Mouf\AmqpClient\Objects\Binding

Complexity

Total Complexity

11

Size/Duplication

Total Lines	172
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	4
Bugs	2	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getRoutingKey()	0	4	1
A	setRoutingKey()	0	6	1
A	getNowait()	0	4	1
A	setNowait()	0	6	1
A	getArguments()	0	4	1
A	setArguments()	0	6	1
A	getTicket()	0	4	1
A	setTicket()	0	6	1
A	__construct()	0	5	1
A	init()	0	16	2

<?php

namespace Mouf\AmqpClient\Objects;

use Mouf\AmqpClient\RabbitMqObjectInterface;
use PhpAmqpLib\Channel\AMQPChannel;

class Binding implements RabbitMqObjectInterface
{
    /**
     * @var Exchange
     */
    private $source;

    /**
     * Routing key.
     *
     * @var string
     */
    private $routing_key = '';

    /**
     * No wait.
     *
     * @var bool
     */
    private $nowait = false;

    /**
     * Arguments.
     *
     * @var array
     */
    private $arguments = null;

    /**
     * Ticket.
     *
     * @var int
     */
    private $ticket = 0;

    /**
     * @var Queue
     */
    private $to;

    /**
     * Parameter to initialize object only one time.
     *
     * @var bool
     */
    private $init = false;

    /**
     * Set the source (Exchange) to the destination (Queue).
     *
     * @param Exchange $source
     * @param Queue    $to
     */
    public function __construct(Exchange $source, Queue $to)
    {
        $this->source = $source;
        $this->to = $to;
    }

    public function init(AMQPChannel $amqpChannel)
    {
        if (!$this->init) {
            $this->source->init($amqpChannel);
            $this->to->init($amqpChannel);

            $amqpChannel->queue_bind($this->to->getName(),
                                        $this->source->getName(),
                                        $this->routing_key,
                                        $this->nowait,
                                        $this->arguments,
                                        $this->ticket);

            $this->init = true;
        }
    }

    /**
     * Get Routing key.
     *
     * @return string
     */
    public function getRoutingKey()
    {
        return $this->routing_key;
    }

    /**
     * Set routing key.
     *
     * @param string $routing_key
     *
     * @return Binding
     */
    public function setRoutingKey($routing_key)
    {
        $this->routing_key = $routing_key;

        return $this;
    }

    /**
     * Get nowait.
     *
     * @return bool
     */
    public function getNowait()
    {
        return $this->nowait;
    }

    /**
     * Set nowait.
     *
     * @param bool $nowait
     *
     * @return Binding
     */
    public function setNowait($nowait)
    {
        $this->nowait = $nowait;

        return $this;
    }

    /**
     * Get arguments.
     *
     * @return array
     */
    public function getArguments()
    {
        return $this->arguments;
    }

    /**
     * Set arguments.
     *
     * @param bool $arguments
     *
     * @return Binding
     */
    public function setArguments(array $arguments)
    {
        $this->arguments = $arguments;

        return $this;
    }

    /**
     * Get ticket.
     *
     * @return int
     */
    public function getTicket()
    {
        return $this->ticket;
    }

    /**
     * Set ticket.
     *
     * @param int $ticket
     *
     * @return Binding
     */
    public function setTicket($ticket)
    {
        $this->ticket = $ticket;

        return $this;
    }
}