Mouf\AmqpClient\Objects\Binding

Complexity

Total Complexity

11

Size/Duplication

Total Lines	143
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__contruct()	0	4	1
A	init()	0	15	2
A	getRoutingKey()	0	3	1
A	setRoutingKey()	0	4	1
A	getNowait()	0	3	1
A	setNowait()	0	4	1
A	getArguments()	0	3	1
A	setArguments()	0	4	1
A	getTicket()	0	3	1
A	setTicket()	0	4	1

<?php
namespace Mouf\AmqpClient\Objects;

use Mouf\AmqpClient\RabbitMqObjectInterface;
use PhpAmqpLib\Connection\AMQPStreamConnection;
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 __contruct(Exchange $source, Queue $to) {
		$this->source = $source;
		$this->to = $to;
	}
	
	public function init(AMQPChannel $amqpChannel) {
		if(!$this->init) {
			$this->source->init();

The call to init() misses a required argument $amqpChannel.

			$this->to->init();

The call to init() misses a required argument $amqpChannel.

			
			$amqpChannel->queue_bind($this->to->getName(),

The method getName() does not seem to exist on object<Mouf\AmqpClient\Objects\Queue>.

										$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;
	}
	
}