Client::getChannel() - Code Metrics - Inspection of "Merging 1.0 in 1.1" - thecodingmachine/oo-amqp-client - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.1 ( be0fbd...d8480c )

by David

created 2018-01-25 15:33 UTC

Client::getChannel() C

↳ Parent: Client

Complexity

Conditions	8
Paths	5

Size

Total Lines	25
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	25
rs	5.3846
c	0
b	0
f	0
cc	8
eloc	14
nc	5
nop	0

<?php

namespace Mouf\AmqpClient;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Channel\AMQPChannel;
use Mouf\AmqpClient\Exception\ConnectionException;

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

    public function register(RabbitMqObjectInterface $object)
    {
        if (!in_array($object, $this->rabbitMqObjects, true)) {
            $this->rabbitMqObjects[] = $object;
        }
    }

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

                /* We are trying to catch the exception when the connection if refused */
                if (preg_match("/.*unable to connect.*Connection refused.*/", $e->__toString())) {
                    throw new ConnectionException("Cannot create the connection", 404, $e);
                }
                throw $e;
            }
            $this->channel = $this->connection->channel();


            if ($this->prefetchSize !== null || $this->prefetchCount !== null || $this->aGlobal !== null) {
                $this->channel->basic_qos($this->prefetchSize, $this->prefetchCount, $this->aGlobal);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            }

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

        return $this->channel;

    }

    /**
     * Returns the list of registered queues.
     *
     * @return QueueInterface[]
     */
    public function getQueues()
    {
        return array_filter($this->rabbitMqObjects, function (RabbitMqObjectInterface $object) {
            return $object instanceof QueueInterface;
        });
    }
}


1			<?php
2
3			namespace Mouf\AmqpClient;
4
5			use PhpAmqpLib\Connection\AMQPStreamConnection;
6			use PhpAmqpLib\Channel\AMQPChannel;
7			use Mouf\AmqpClient\Exception\ConnectionException;
8
9			class Client
10			{
11			/**
12			* RabbitMq host.
13			*
14			* @var string
15			*/
16			private $host;
17
18			/**
19			* RabbitMq port.
20			*
21			* @var string
22			*/
23			private $port;
24
25			/**
26			* RabbitMq user.
27			*
28			* @var string
29			*/
30			private $user;
31
32			/**
33			* RabbitMq password.
34			*
35			* @var string
36			*/
37			private $password;
38
39			/**
40			* It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.
41			*
42			* @var int
43			*/
44			private $prefetchSize = null;
45
46			/**
47			* It's for QOS prefetch-count http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.
48			*
49			* @var int
50			*/
51			private $prefetchCount = null;
52
53			/**
54			* It's for QOS global http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.
55			*
56			* @var int
57			*/
58			private $aGlobal = null;
59
60			/**
61			* RabbitMq connection.
62			*
63			* @var AMQPStreamConnection
64			*/
65			private $connection = null;
66
67			/**
68			* RabbitMq channel.
69			*
70			* @var \AMQPChannel
71			*/
72			private $channel = null;
73
74			/**
75			* List of RabbitMq object.
76			*
77			* @var RabbitMqObjectInterface[]
78			*/
79			private $rabbitMqObjects = [];
80
81			public function __construct($host, $port, $user, $password)
82			{
83			$this->host = $host;
84			$this->port = ($port !== null) ? $port : 5672;
85			$this->user = $user;
86			$this->password = $password;
87			}
88
89			/**
90			* Get prefetch size for QOS.
91			*/
92			public function getPrefetchSize()
93			{
94			return $this->prefetchSize;
95			}
96
97			/**
98			* Set prefetch size
99			* It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.
100			*
101			* @param int $prefetchSize
102			*/
103			public function setPrefetchSize($prefetchSize)
104			{
105			$this->prefetchSize = $prefetchSize;
106
107			return $this;
108			}
109
110			/**
111			* Get prefetch count for QOS.
112			*/
113			public function getPrefetchCount()
114			{
115			return $this->prefetchCount;
116			}
117
118			/**
119			* Set prefetch size
120			* It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.
121			*
122			* @param int $prefetchCount
123			*/
124			public function setPrefetchCount($prefetchCount)
125			{
126			$this->prefetchCount = $prefetchCount;
127
128			return $this;
129			}
130
131			/**
132			* Get a global for QOS.
133			*/
134			public function getAGlobal()
135			{
136			return $this->aGlobal;
137			}
138
139			/**
140			* Set global
141			* It's for QOS prefetch-size http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.
142			*
143			* @param int $aGlobal
144			*/
145			public function setAGlobal($aGlobal)
146			{
147			$this->aGlobal = $aGlobal;
148
149			return $this;
150			}
151
152			/**
153			* Set RabbitMq object.
154			*
155			* @param RabbitMqObjectInterface[] $rabbitMqObjects
156			*/
157			public function setRabbitMqObjects(array $rabbitMqObjects)
158			{
159			$this->rabbitMqObjects = $rabbitMqObjects;
160			}
161
162			public function register(RabbitMqObjectInterface $object)
163			{
164			if (!in_array($object, $this->rabbitMqObjects, true)) {
165			$this->rabbitMqObjects[] = $object;
166			}
167			}
168
169			/**
170			* Connection to the RabbitMq service with AMQPStreamConnection.
171			*
172			* @return AMQPChannel
173			*/
174			public function getChannel()
175			{
176			if (!$this->connection) {
177			try {
178			$this->connection = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->password);
179			} catch (\ErrorException $e) {
			0 ignored issues – show Bug introduced 2018-01-25 15:44 UTC by Report Bug Copy Issue Report The class `ErrorException` does not exist. Did you forget a USE statement, or did you not list all dependencies? Scrutinizer analyzes your `composer.json`/`composer.lock` file if available to determine the classes, and functions that are defined by your dependencies. It seems like the listed class was neither found in your dependencies, nor was it found in the analyzed files in your repository. If you are using some other form of dependency management, you might want to disable this analysis. Loading history...
180			/* We are trying to catch the exception when the connection if refused */
181			if (preg_match("/.unable to connect.Connection refused.*/", $e->__toString())) {
182			throw new ConnectionException("Cannot create the connection", 404, $e);
183			}
184			throw $e;
185			}
186			$this->channel = $this->connection->channel();
			0 ignored issues – show Documentation Bug introduced 2016-07-07 13:54 UTC by Report Bug Copy Issue Report It seems like `$this->connection->channel()` of type `object<PhpAmqpLib\Channel\AMQPChannel>` is incompatible with the declared type `object<AMQPChannel>` of property `$channel`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
187
188			if ($this->prefetchSize !== null \|\| $this->prefetchCount !== null \|\| $this->aGlobal !== null) {
189			$this->channel->basic_qos($this->prefetchSize, $this->prefetchCount, $this->aGlobal);
			0 ignored issues – show Documentation introduced 2016-07-07 16:27 UTC by Report Bug Copy Issue Report `$this->aGlobal` is of type `integer`, but the function expects a `boolean`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
190			}
191
192			foreach ($this->rabbitMqObjects as $rabbitMqObject) {
193			$rabbitMqObject->init($this->channel);
194			}
195			}
196
197			return $this->channel;
			0 ignored issues – show Bug Compatibility introduced 2016-07-07 13:54 UTC by Report Bug Copy Issue Report The expression `$this->channel;` of type `PhpAmqpLib\Channel\AMQPChannel\|AMQPChannel` adds the type `AMQPChannel` to the return on line 197 which is incompatible with the return type documented by `Mouf\AmqpClient\Client::getChannel` of type `PhpAmqpLib\Channel\AMQPChannel`. Loading history...
198			}
199
200			/**
201			* Returns the list of registered queues.
202			*
203			* @return QueueInterface[]
204			*/
205			public function getQueues()
206			{
207			return array_filter($this->rabbitMqObjects, function (RabbitMqObjectInterface $object) {
208			return $object instanceof QueueInterface;
209			});
210			}
211			}
212

thecodingmachine / oo-amqp-client

Push — 1.1 ( be0fbd...d8480c )

Client::getChannel() C

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like