Channel::isConnected() - Code Metrics - Inspection of "phpunit composer dep" - thomasvargiu/AMQPAL - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( f55883...4285c1 )

by Thomas Mauro

created 2016-03-22 19:18 UTC

Channel::isConnected() A

↳ Parent: Channel

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	4
ccs	2
cts	2
cp	1
rs	10
cc	1
eloc	2
nc	1
nop	0
crap	1

<?php

namespace AMQPAL\Adapter\PhpAmqpLib;

use PhpAmqpLib\Channel\AMQPChannel;
use AMQPAL\Adapter\ChannelInterface;
use AMQPAL\Adapter\ConnectionInterface;
use AMQPAL\Adapter\ExchangeInterface;
use AMQPAL\Adapter\QueueInterface;
use AMQPAL\Options;

/**
 * Class Channel
 *
 * @package AMQPAL\Adapter\PhpAmqpLib
 */
class Channel implements ChannelInterface
{

    /**
     * @var AMQPChannel
     */
    protected $resource;
    /**
     * @var ConnectionInterface
     */
    protected $connection;
    /**
     * @var Exchange
     */
    protected $exchangePrototype;
    /**
     * @var Queue
     */
    protected $queuePrototype;

    /**
     * Channel constructor.
     *
     * @param Exchange $exchangePrototype
     * @param Queue    $queuePrototype
     */
    public function __construct(Exchange $exchangePrototype = null, Queue $queuePrototype = null)
    {
        $this->registerExchange($exchangePrototype ?: new Exchange());
        $this->registerQueue($queuePrototype ?: new Queue());
    }

    /**
     * @param Exchange $exchange
     */
    public function registerExchange(Exchange $exchange)
    {
        $this->exchangePrototype = $exchange;
    }

    /**
     * @param Queue $queue
     */
    public function registerQueue(Queue $queue)
    {
        $this->queuePrototype = $queue;
    }

    /**
     * @return AMQPChannel
     */
    public function getResource()
    {
        return $this->resource;
    }

    /**
     * @param AMQPChannel $resource
     * @return $this
     */
    public function setResource(AMQPChannel $resource)
    {
        $this->resource = $resource;

        return $this;
    }

    /**
     * Check the channel connection.
     *
     * @return bool Indicates whether the channel is connected.
     */
    public function isConnected()
    {
        return $this->getConnection()->isConnected();
    }

    /**
     * Return internal channel ID
     *
     * @return integer
     */
    public function getChannelId()
    {
        return $this->getResource()->getChannelId();
    }

    /**
     * Set the window size and the number of messages to prefetch from the broker.
     *
     * @param int $prefetchSize  The window size, in octets, to prefetch.
     * @param int $prefetchCount The number of messages to prefetch.
     * @return $this
     */
    public function setQos($prefetchSize, $prefetchCount)
    {
        $this->getResource()->basic_qos($prefetchSize, $prefetchCount, false);

        return $this;
    }

    /**
     * Start a transaction.
     *
     * @return $this
     */
    public function startTransaction()
    {
        $this->getResource()->tx_select();

        return $this;
    }

    /**
     * Commit a pending transaction.
     *
     * @return $this
     */
    public function commitTransaction()
    {
        $this->getResource()->tx_commit();

        return $this;
    }

    /**
     * Rollback a transaction.
     *
     * @return $this
     */
    public function rollbackTransaction()
    {
        $this->getResource()->tx_rollback();

        return $this;
    }

    /**
     * @param Connection $connection
     * @return $this
     */
    public function setConnection(Connection $connection)
    {
        $this->connection = $connection;
        return $this;
    }

    /**
     * Get the connection object in use
     *
     * @return Connection
     */
    public function getConnection()
    {
        return $this->connection;
    }

    /**
     * Redeliver unacknowledged messages.
     *
     * @param bool $requeue
     * @return $this
     */
    public function basicRecover($requeue = true)
    {
        $this->getResource()->basic_recover($requeue);

        return $this;
    }

    /**
     * Create a new queue
     *
     * @param Options\QueueOptions $options
     * @return QueueInterface
     */
    public function createQueue(Options\QueueOptions $options)
    {
        $queue = clone $this->queuePrototype;

        $queue->setChannel($this);
        $queue->setOptions($options);

        return $queue;
    }

    /**
     * Create a new exchange
     *
     * @param Options\ExchangeOptions $options
     * @return ExchangeInterface
     */
    public function createExchange(Options\ExchangeOptions $options)
    {
        $exchange = clone $this->exchangePrototype;

        $exchange->setChannel($this);
        $exchange->setOptions($options);

        return $exchange;
    }
}


1		<?php
2
3		namespace AMQPAL\Adapter\PhpAmqpLib;
4
5		use PhpAmqpLib\Channel\AMQPChannel;
6		use AMQPAL\Adapter\ChannelInterface;
7		use AMQPAL\Adapter\ConnectionInterface;
8		use AMQPAL\Adapter\ExchangeInterface;
9		use AMQPAL\Adapter\QueueInterface;
10		use AMQPAL\Options;
11
12		/**
13		* Class Channel
14		*
15		* @package AMQPAL\Adapter\PhpAmqpLib
16		*/
17		class Channel implements ChannelInterface
18		{
19
20		/**
21		* @var AMQPChannel
22		*/
23		protected $resource;
24		/**
25		* @var ConnectionInterface
26		*/
27		protected $connection;
28		/**
29		* @var Exchange
30		*/
31		protected $exchangePrototype;
32		/**
33		* @var Queue
34		*/
35		protected $queuePrototype;
36
37		/**
38		* Channel constructor.
39		*
40		* @param Exchange $exchangePrototype
41		* @param Queue $queuePrototype
42		*/
43	13	public function __construct(Exchange $exchangePrototype = null, Queue $queuePrototype = null)
44		{
45	13	$this->registerExchange($exchangePrototype ?: new Exchange());
46	13	$this->registerQueue($queuePrototype ?: new Queue());
47	13	}
48
49		/**
50		* @param Exchange $exchange
51		*/
52	13	public function registerExchange(Exchange $exchange)
53		{
54	13	$this->exchangePrototype = $exchange;
55	13	}
56
57		/**
58		* @param Queue $queue
59		*/
60	13	public function registerQueue(Queue $queue)
61		{
62	13	$this->queuePrototype = $queue;
63	13	}
64
65		/**
66		* @return AMQPChannel
67		*/
68	8	public function getResource()
69		{
70	8	return $this->resource;
71		}
72
73		/**
74		* @param AMQPChannel $resource
75		* @return $this
76		*/
77	9	public function setResource(AMQPChannel $resource)
78		{
79	9	$this->resource = $resource;
80
81	9	return $this;
82		}
83
84		/**
85		* Check the channel connection.
86		*
87		* @return bool Indicates whether the channel is connected.
88		*/
89	1	public function isConnected()
90		{
91	1	return $this->getConnection()->isConnected();
92		}
93
94		/**
95		* Return internal channel ID
96		*
97		* @return integer
98		*/
99	1	public function getChannelId()
100		{
101	1	return $this->getResource()->getChannelId();
102		}
103
104		/**
105		* Set the window size and the number of messages to prefetch from the broker.
106		*
107		* @param int $prefetchSize The window size, in octets, to prefetch.
108		* @param int $prefetchCount The number of messages to prefetch.
109		* @return $this
110		*/
111	1	public function setQos($prefetchSize, $prefetchCount)
112		{
113	1	$this->getResource()->basic_qos($prefetchSize, $prefetchCount, false);
114
115	1	return $this;
116		}
117
118		/**
119		* Start a transaction.
120		*
121		* @return $this
122		*/
123	1	public function startTransaction()
124		{
125	1	$this->getResource()->tx_select();
126
127	1	return $this;
128		}
129
130		/**
131		* Commit a pending transaction.
132		*
133		* @return $this
134		*/
135	1	public function commitTransaction()
136		{
137	1	$this->getResource()->tx_commit();
138
139	1	return $this;
140		}
141
142		/**
143		* Rollback a transaction.
144		*
145		* @return $this
146		*/
147	1	public function rollbackTransaction()
148		{
149	1	$this->getResource()->tx_rollback();
150
151	1	return $this;
152		}
153
154		/**
155		* @param Connection $connection
156		* @return $this
157		*/
158	2	public function setConnection(Connection $connection)
159		{
160	2	$this->connection = $connection;
161	2	return $this;
162		}
163
164		/**
165		* Get the connection object in use
166		*
167		* @return Connection
168		*/
169	2	public function getConnection()
170		{
171	2	return $this->connection;
172		}
173
174		/**
175		* Redeliver unacknowledged messages.
176		*
177		* @param bool $requeue
178		* @return $this
179		*/
180	2	public function basicRecover($requeue = true)
181		{
182	2	$this->getResource()->basic_recover($requeue);
183
184	2	return $this;
185		}
186
187		/**
188		* Create a new queue
189		*
190		* @param Options\QueueOptions $options
191		* @return QueueInterface
192		*/
193	1	public function createQueue(Options\QueueOptions $options)
194		{
195	1	$queue = clone $this->queuePrototype;
196
197	1	$queue->setChannel($this);
198	1	$queue->setOptions($options);
199
200	1	return $queue;
201		}
202
203		/**
204		* Create a new exchange
205		*
206		* @param Options\ExchangeOptions $options
207		* @return ExchangeInterface
208		*/
209	1	public function createExchange(Options\ExchangeOptions $options)
210		{
211	1	$exchange = clone $this->exchangePrototype;
212
213	1	$exchange->setChannel($this);
214	1	$exchange->setOptions($options);
215
216	1	return $exchange;
217		}
218		}
219

thomasvargiu / AMQPAL

Push — master ( f55883...4285c1 )

Channel::isConnected() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like