Binding::init() - Code Metrics - Inspection of "Working on tests" - thecodingmachine/oo-amqp-client - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.0 ( 3cba8a...ca5b13 )

by David

created 2016-07-07 13:51 UTC

Binding::init() A

↳ Parent: Binding

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	1

Metric	Value
c	2
b	0
f	1
dl	0
loc	15
rs	9.4285
cc	2
eloc	11
nc	2
nop	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();

			$this->to->init();

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

1			<?php
2			namespace Mouf\AmqpClient\Objects;
3
4			use Mouf\AmqpClient\RabbitMqObjectInterface;
5			use PhpAmqpLib\Connection\AMQPStreamConnection;
6			use PhpAmqpLib\Channel\AMQPChannel;
7
8			class Binding implements RabbitMqObjectInterface{
9
10			/**
11			*
12			* @var Exchange
13			*/
14			private $source;
15
16			/**
17			* Routing key
18			* @var string
19			*/
20			private $routing_key = '';
21
22			/**
23			* No wait
24			* @var bool
25			*/
26			private $nowait = false;
27
28			/**
29			* Arguments
30			* @var array
31			*/
32			private $arguments = null;
33
34			/**
35			* Ticket
36			* @var int
37			*/
38			private $ticket = 0;
39
40			/**
41			*
42			* @var Queue
43			*/
44			private $to;
45
46			/**
47			* Parameter to initialize object only one time
48			* @var bool
49			*/
50			private $init = false;
51
52			/**
53			* Set the source (Exchange) to the destination (Queue)
54			* @param Exchange $source
55			* @param Queue $to
56			*/
57			public function __contruct(Exchange $source, Queue $to) {
58			$this->source = $source;
59			$this->to = $to;
60			}
61
62			public function init(AMQPChannel $amqpChannel) {
63			if(!$this->init) {
64			$this->source->init();
			0 ignored issues – show Bug introduced 2016-07-07 13:54 UTC by Report Bug Copy Issue Report The call to `init()` misses a required argument `$amqpChannel`. This check looks for function calls that miss required arguments. Loading history...
65			$this->to->init();
			0 ignored issues – show Bug introduced 2016-07-07 13:54 UTC by Report Bug Copy Issue Report The call to `init()` misses a required argument `$amqpChannel`. This check looks for function calls that miss required arguments. Loading history...
66
67			$amqpChannel->queue_bind($this->to->getName(),
			0 ignored issues – show Bug introduced 2016-07-07 13:54 UTC by Report Bug Copy Issue Report The method `getName()` does not seem to exist on `object<Mouf\AmqpClient\Objects\Queue>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
68			$this->source->getName(),
69			$this->routing_key,
70			$this->nowait,
71			$this->arguments,
72			$this->ticket);
73
74			$this->init = true;
75			}
76			}
77
78			/**
79			* Get Routing key
80			* @return string
81			*/
82			public function getRoutingKey() {
83			return $this->routing_key;
84			}
85
86			/**
87			* Set routing key
88			* @param string $routing_key
89			* @return Binding
90			*/
91			public function setRoutingKey($routing_key) {
92			$this->routing_key = $routing_key;
93			return $this;
94			}
95
96			/**
97			* Get nowait
98			* @return bool
99			*/
100			public function getNowait() {
101			return $this->nowait;
102			}
103
104			/**
105			* Set nowait
106			* @param bool $nowait
107			* @return Binding
108			*/
109			public function setNowait($nowait) {
110			$this->nowait = $nowait;
111			return $this;
112			}
113
114			/**
115			* Get arguments
116			* @return array
117			*/
118			public function getArguments() {
119			return $this->arguments;
120			}
121
122			/**
123			* Set arguments
124			* @param bool $arguments
125			* @return Binding
126			*/
127			public function setArguments(array $arguments) {
128			$this->arguments = $arguments;
129			return $this;
130			}
131
132			/**
133			* Get ticket
134			* @return int
135			*/
136			public function getTicket() {
137			return $this->ticket;
138			}
139
140			/**
141			* Set ticket
142			* @param int $ticket
143			* @return Binding
144			*/
145			public function setTicket($ticket) {
146			$this->ticket = $ticket;
147			return $this;
148			}
149
150			}

thecodingmachine / oo-amqp-client

Push — 1.0 ( 3cba8a...ca5b13 )

Binding::init() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like