Mouf\AmqpClient\Client

Complexity

Total Complexity

15

Size/Duplication

Total Lines	154
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	3
Bugs	0	Features	1

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	getPrefetchSize()	0	3	1
A	setPrefetchSize()	0	4	1
A	getPrefetchCount()	0	3	1
A	setPrefetchCount()	0	4	1
A	getAGlobal()	0	3	1
A	setAGlobal()	0	4	1
A	setRabbitMqObjects()	0	3	1
B	getChannel()	0	16	6

<?php
namespace Mouf\AmqpClient;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Channel\AMQPChannel;

class Client {
	
	/**
	 * RabbitMq host
	 * @var string
	 */
	private $host;
	
	/**
	 * RabbitMq port
	 * @var string
	 */
	private $port;
	
	/**
	 * RabbitMq user
	 * @var string
	 */
	private $user;
	
	/**
	 * RabbitMq password
	 * @var string
	 */
	private $password;
	
	/**
	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
	 * @var int
	 */
	private $prefetchSize = null;
	
	/**
	 * It's for QOS prefetch-count http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
	 * @var int
	 */
	private $prefetchCount = null;
	
	/**
	 * It's for QOS global http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
	 * @var int
	 */
	private $aGlobal = null;
	
	/**
	 * RabbitMq connection
	 * @var AMQPStreamConnection
	 */
	private $connection = null;
	
	/**
	 * RabbitMq channel
	 * @var \AMQPChannel
	 */
	private $channel = null;
	
	/**
	 * List of RabbitMq object
	 * @var RabbitMqObjectInterface
	 */
	private $rabbitMqObjects = [];
	
	public function __construct($host, $port, $user, $password) {
		$this->host = $host;
		$this->port = ($port !== null) ? $port : 5672;
		$this->user = $user;
		$this->password = $password;
	}

	/**
	 * Get prefetch size for QOS
	 */
	public function getPrefetchSize() {
		return $this->prefetchSize;
	}
	
	/**
	 * Set prefetch size
	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
	 * 
	 * @param int $prefetchSize
	 */
	public function setPrefetchSize($prefetchSize) {
		$this->prefetchSize = $prefetchSize;
		return $this;
	}
	
	/**
	 * Get prefetch count for QOS
	 */
	public function getPrefetchCount() {
		return $this->prefetchCount;
	}
	
	/**
	 * Set prefetch size
	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
	 * 
	 * @param int $prefetchCount
	 */
	public function setPrefetchCount($prefetchCount) {
		$this->prefetchCount = $prefetchCount;
		return $this;
	}
	
	/**
	 * Get a global for QOS
	 */
	public function getAGlobal() {
		return $this->aGlobal;
	}
	
	/**
	 * Set global
	 * It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos
	 * 
	 * @param int $aGlobal
	 */
	public function setAGlobal($aGlobal) {
		$this->aGlobal = $aGlobal;
		return $this;
	}
	
	/**
	 * Set RabbitMq object
	 * @param RabbitMqObjectInterface[] $rabbitMqObjects
	 */
	public function setRabbitMqObjects(array $rabbitMqObjects) {
		$this->rabbitMqObjects = $rabbitMqObjects;

It seems like $rabbitMqObjects of type array<integer,object<Mouf\AmqpClient\RabbitMqObjectInterface>> is incompatible with the declared type object<Mouf\AmqpClient\RabbitMqObjectInterface> of property $rabbitMqObjects.

	}
	
	/**
	 * Connection to the RabbitMq service with AMQPStreamConnection
	 *
	 * @return AMQPChannel
	 */
	public function getChannel() {
		if(!$this->connection) {
			$this->connection = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->password);

			$this->channel = $this->connection->channel();

It seems like $this->connection->channel() of type object<PhpAmqpLib\Channel\AMQPChannel> is incompatible with the declared type object<AMQPChannel> of property $channel.

			
 			if($this->prefetchCount !== null || $this->prefetchCount !== null || $this->aGlobal !== null) {
				$this->channel->basic_qos(null, 1, null);

null is of type null, but the function expects a boolean.

 			}
			
			foreach ($this->rabbitMqObjects as $rabbitMqObject) {

The expression $this->rabbitMqObjects of type object<Mouf\AmqpClient\RabbitMqObjectInterface> is not traversable.

				$rabbitMqObject->init($this->channel);
			}
		}
		return $this->channel;

The expression $this->channel; of type PhpAmqpLib\Channel\AMQPChannel|AMQPChannel adds the type AMQPChannel to the return on line 157 which is incompatible with the return type documented by Mouf\AmqpClient\Client::getChannel of type PhpAmqpLib\Channel\AMQPChannel.

	}
	
}