Queue::publish() - Code Metrics - Inspection of "Adding support to send messages directly on queues" - thecodingmachine/oo-amqp-client - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.1 ( 12efad )

by David

created 2016-12-07 10:57 UTC

Queue::publish() A

↳ Parent: Queue

Complexity

Conditions	1
Paths	1

Size

Total Lines	8
Code Lines	5

Duplication

Lines	8
Ratio	100 %

Importance

Changes

Metric	Value
c	0
b	0
f	0
dl	8
loc	8
rs	9.4285
cc	1
eloc	5
nc	1
nop	4

<?php

namespace Mouf\AmqpClient\Objects;

use Mouf\AmqpClient\Client;
use Mouf\AmqpClient\QueueInterface;
use Mouf\AmqpClient\RabbitMqObjectInterface;
use PhpAmqpLib\Channel\AMQPChannel;
use Mouf\AmqpClient\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;

/**
 * @author Marc
 */
class Queue implements RabbitMqObjectInterface, QueueInterface
{
    /**
     * @var Client
     */
    private $client;

    /**
     * Queue name.
     *
     * @var string
     */
    private $name;

    /**
     * Passive.
     *
     * @var bool
     */
    private $passive = false;

    /**
     * Durable.
     *
     * @var bool
     */
    private $durable = false;

    /**
     * Exclusive.
     *
     * @var bool
     */
    private $exclusive = false;

    /**
     * Auto delete.
     *
     * @var bool
     */
    private $autoDelete = false;

    /**
     * No wait.
     *
     * @var bool
     */
    private $noWait = false;

    /**
     * Ticket.
     *
     * @var int
     */
    private $ticket = null;

    /**
     * RabbitMq specific parameter : x-dead-letter-exchange.
     *
     * @var Exchange
     */
    private $deadLetterExchanger = null;

    /**
     * RabbitMq specific parameter : confirm.
     *
     * @var int
     */
    private $confirm = null;

    /**
     * RabbitMq specific parameter : consumer_cancel_notify.
     *
     * @var bool
     */
    private $consumerCancelNotify = null;

    /**
     * RabbitMq specific parameter : alternate-exchange.
     *
     * @var Queue
     */
    private $alternateExchange = null;

    /**
     * RabbitMq specific parameter : x-message-ttl.
     *
     * @var int
     */
    private $ttl = null;

    /**
     * RabbitMq specific parameter : x-max-length.
     *
     * @var int
     */
    private $maxLength = null;

    /**
     * RabbitMq specific parameter : x-max-priority.
     *
     * @var int
     */
    private $maxPriority = null;

    /**
     * Parameter to initialize object only one time.
     *
     * @var bool
     */
    private $init = false;

    /**
     * Consumer list implement ConsumerInterface.
     *
     * @var array
     */
    private $consumers;

    /**
     * Set the source (Binding).
     *
     * @param Binding             $source
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param string              $name
     * @param ConsumerInterface[] $consumers
     */
    public function __construct(Client $client, $name, array $consumers = [])
    {
        $this->client = $client;
        $this->client->register($this);
        $this->name = $name;
        $this->consumers = $consumers;
    }

    /**
     * Get queue name.
     *
     * @return string
     */
    public function getName()
    {
        return $this->name;
    }

    /**
     * Get passive.
     *
     * @return bool
     */
    public function getPassive()
    {
        return $this->passive;
    }

    /**
     * @param bool $passive
     *
     * @return Queue
     */
    public function setPassive($passive)
    {
        $this->passive = $passive;

        return $this;
    }

    /**
     * Get durable.
     *
     * @return bool
     */
    public function getDurable()
    {
        return $this->durable;
    }

    /**
     * Set durable.
     *
     * @param bool $durable
     *
     * @return Queue
     */
    public function setDurable($durable)
    {
        $this->durable = $durable;

        return $this;
    }

    /**
     * Get exclusive.
     *
     * @return bool
     */
    public function getExclusive()
    {
        return $this->exclusive;
    }

    /**
     * Set exclusive.
     *
     * @param bool $exclusive
     *
     * @return Queue
     */
    public function setExclusive($exclusive)
    {
        $this->exclusive = $exclusive;

        return $this;
    }

    /**
     * Get autoDelete.
     *
     * @return bool
     */
    public function getAutoDelete()
    {
        return $this->autoDelete;
    }

    /**
     * Set autoDelete.
     *
     * @param bool $autoDelete
     *
     * @return Queue
     */
    public function setAutoDelete($autoDelete)
    {
        $this->autoDelete = $autoDelete;

        return $this;
    }

    /**
     * Get noWait.
     *
     * @return bool
     */
    public function getNoWait()
    {
        return $this->noWait;
    }

    /**
     * Set noWait.
     *
     * @param bool $noWait
     *
     * @return Queue
     */
    public function setNoWait($noWait)
    {
        $this->noWait = $noWait;

        return $this;
    }

    /**
     * Get arguments.
     *
     * @return array|null
     */
    public function getArguments()
    {
        return $this->arguments;
class MyClass { }

$x = new MyClass();
$x->foo = true;
    }

    /**
     * Set arguments.
     *
     * @param array $arguments
     *
     * @return Queue
     */
    public function setArguments($arguments)
    {
        $this->arguments = $arguments;

        return $this;
    }

    /**
     * Get ticket.
     *
     * @return int
     */
    public function getTicket()
    {
        return $this->ticket;
    }

    /**
     * Set ticket.
     *
     * @param int $ticket
     *
     * @return Queue
     */
    public function setTicket($ticket)
    {
        $this->ticket = $ticket;

        return $this;
    }

    /**
     * Get RabbitMq specific parameter : dead letter queue.
     *
     * @return Queue
     */
    public function getDeadLetterExchanger()
    {
        return $this->deadLetterExchanger;
    }

    /**
     * Set RabbitMq specific parameter : dead letter queue.
     *
     * @param Exchange $exchange
     *
     * @return Queue
     */
    public function setDeadLetterExchange(Exchange $exchange)
    {
        $this->deadLetterExchanger = $exchange;

        return $this;
    }

    /**
     * Get RabbitMq specific parameter : confirm.
     *
     * @return int
     */
    public function getConfirm()
    {
        return $this->confirm;
    }

    /**
     * Set RabbitMq specific parameter : confirm.
     *
     * @param int $confirm
     *
     * @return Queue
     */
    public function setConfirm($confirm)
    {
        $this->confirm = $confirm;

        return $this;
    }

    /**
     * Get RabbitMq specific parameter : consumer_cancel_notify.
     *
     * @return bool
     */
    public function getConsumerCancelNotify()
    {
        return $this->consumerCancelNotify;
    }

    /**
     * Set RabbitMq specific parameter : consumer_cancel_notify.
     *
     * @param Queue $consumerCancelNotify
     *
     * @return Queue
     */
    public function setConsumerCancelNotify(Queue $consumerCancelNotify)
    {
        $this->consumerCancelNotify = $consumerCancelNotify;


        return $this;
    }

    /**
     * Get RabbitMq specific parameter : alternate_exchange.
     *
     * @return Queue
     */
    public function getAlternateExchange()
    {
        return $this->alternateExchange;
    }

    /**
     * Set RabbitMq specific parameter : alternate_exchange.
     *
     * @param Queue $alternateExchange
     *
     * @return Queue
     */
    public function setAlternateExchange(Queue $alternateExchange)
    {
        $this->alternateExchange = $alternateExchange;

        return $this;
    }

    /**
     * Get RabbitMq specific parameter : ttl.
     *
     * @return int
     */
    public function getTtl()
    {
        return $this->ttl;
    }

    /**
     * Set RabbitMq specific parameter : ttl.
     *
     * @param int $ttl
     *
     * @return Queue
     */
    public function setTtl($ttl)
    {
        $this->ttl = $ttl;

        return $this;
    }

    /**
     * Get RabbitMq specific parameter : max length.
     *
     * @return int
     */
    public function getMaxLength()
    {
        return $this->maxLength;
    }

    /**
     * Set RabbitMq specific parameter : max length.
     *
     * @param int $maxLength
     *
     * @return Queue
     */
    public function setMaxLength($maxLength)
    {
        $this->maxLength = $maxLength;

        return $this;
    }

    /**
     * Get RabbitMq specific parameter : max priority.
     *
     * @return int
     */
    public function getMaxPriority()
    {
        return $this->maxPriority;
    }

    /**
     * Set RabbitMq specific parameter : max priority.
     *
     * @param int $maxPriority
     *
     * @return Queue
     */
    public function setMaxPriority($maxPriority)
    {
        $this->maxPriority = $maxPriority;

        return $this;
    }

    public function init(AMQPChannel $amqpChannel)
    {
        if (!$this->init) {
            if ($this->deadLetterExchanger) {
                $this->deadLetterExchanger->init($amqpChannel);
            }

            $parameters = [];
            if ($this->alternateExchange !== null) {
                $parameters['alternate-exchange'] = ['S', $this->alternateExchange->getName()];
            }
            if ($this->confirm !== null) {
                $parameters['confirm'] = ['I', $this->confirm];
            }
            if ($this->consumerCancelNotify !== null) {
                $parameters['consumer_cancel_notify'] = ['I', $this->consumerCancelNotify];
            }
            if ($this->deadLetterExchanger !== null) {
                $parameters['x-dead-letter-exchange'] = ['S', $this->deadLetterExchanger->getName()];
            }
            if ($this->maxLength) {
                $parameters['x-max-length'] = ['I', $this->maxLength];
            }
            if ($this->maxPriority) {
                $parameters['x-max-priority'] = ['I', $this->maxPriority];
            }
            if ($this->ttl) {
                $parameters['x-message-ttl'] = ['I', $this->ttl];
            }

            if (!$parameters) {

                $parameters = null;
            }
            $amqpChannel->queue_declare($this->name, $this->passive, $this->durable, $this->exclusive, $this->autoDelete, $this->noWait, $parameters);
            $this->init = true;
        }
    }

    /**
     * Sends to RabbitMQ the order to subscribe to the consumers.
     */
    public function consume()
    {
        $channel = $this->client->getChannel();

        foreach ($this->consumers as $consumer) {
            /* @var $consumer ConsumerInterface */
            $channel->basic_consume($this->name,
                                    $consumer->getConsumerTag(),
                                    $consumer->isNoLocal(),
                                    $consumer->isNoAck(),
                                    $consumer->isExclusive(),
                                    $consumer->isNoWait(),
                                    function (AMQPMessage $msg) use ($consumer) {
                                        $consumer->callback($msg);
                                    },
                                    $consumer->getTicket(),
                                    $consumer->getArguments());
        }
    }

    /**
     * Unsubscribes consumers.
     */
    public function cancelConsume()
    {
        $channel = $this->client->getChannel();

        foreach ($this->consumers as $consumer) {
            /* @var $consumer ConsumerInterface */
            $channel->basic_cancel($consumer->getConsumerTag(),
                $consumer->isNoWait());
        }
    }

    /**
     * Sends a message directly to this queue (skipping any exchange).
     *
     * This is a RabbitMQ only feature. Behind the scene, it will dispatch the message to the default RabbitMQ exchange.
     *
     * @param Message $message
     * @param bool $mandatory
     * @param bool $immediate
     * @param null $ticket
     */
    public function publish(Message $message, $mandatory = false,

                            $immediate = false,
                            $ticket = null)
    {
        $channel = $this->client->getChannel();

        $channel->basic_publish($message->toAMQPMessage(), '', $this->name, $mandatory, $immediate, $ticket);
    }
}


1		<?php
2
3		namespace Mouf\AmqpClient\Objects;
4
5		use Mouf\AmqpClient\Client;
6		use Mouf\AmqpClient\QueueInterface;
7		use Mouf\AmqpClient\RabbitMqObjectInterface;
8		use PhpAmqpLib\Channel\AMQPChannel;
9		use Mouf\AmqpClient\ConsumerInterface;
10		use PhpAmqpLib\Message\AMQPMessage;
11
12		/**
13		* @author Marc
14		*/
15		class Queue implements RabbitMqObjectInterface, QueueInterface
16		{
17		/**
18		* @var Client
19		*/
20		private $client;
21
22		/**
23		* Queue name.
24		*
25		* @var string
26		*/
27		private $name;
28
29		/**
30		* Passive.
31		*
32		* @var bool
33		*/
34		private $passive = false;
35
36		/**
37		* Durable.
38		*
39		* @var bool
40		*/
41		private $durable = false;
42
43		/**
44		* Exclusive.
45		*
46		* @var bool
47		*/
48		private $exclusive = false;
49
50		/**
51		* Auto delete.
52		*
53		* @var bool
54		*/
55		private $autoDelete = false;
56
57		/**
58		* No wait.
59		*
60		* @var bool
61		*/
62		private $noWait = false;
63
64		/**
65		* Ticket.
66		*
67		* @var int
68		*/
69		private $ticket = null;
70
71		/**
72		* RabbitMq specific parameter : x-dead-letter-exchange.
73		*
74		* @var Exchange
75		*/
76		private $deadLetterExchanger = null;
77
78		/**
79		* RabbitMq specific parameter : confirm.
80		*
81		* @var int
82		*/
83		private $confirm = null;
84
85		/**
86		* RabbitMq specific parameter : consumer_cancel_notify.
87		*
88		* @var bool
89		*/
90		private $consumerCancelNotify = null;
91
92		/**
93		* RabbitMq specific parameter : alternate-exchange.
94		*
95		* @var Queue
96		*/
97		private $alternateExchange = null;
98
99		/**
100		* RabbitMq specific parameter : x-message-ttl.
101		*
102		* @var int
103		*/
104		private $ttl = null;
105
106		/**
107		* RabbitMq specific parameter : x-max-length.
108		*
109		* @var int
110		*/
111		private $maxLength = null;
112
113		/**
114		* RabbitMq specific parameter : x-max-priority.
115		*
116		* @var int
117		*/
118		private $maxPriority = null;
119
120		/**
121		* Parameter to initialize object only one time.
122		*
123		* @var bool
124		*/
125		private $init = false;
126
127		/**
128		* Consumer list implement ConsumerInterface.
129		*
130		* @var array
131		*/
132		private $consumers;
133
134		/**
135		* Set the source (Binding).
136		*
137		* @param Binding $source
		0 ignored issues – show Bug introduced 2016-07-07 16:27 UTC by Report Bug Copy Issue Report There is no parameter named `$source`. Was it maybe removed? This check looks for PHPDoc comments describing methods or function parameters that do not exist on the corresponding method or function. Consider the following example. The parameter `$italy` is not defined by the method `finale(...)`. /** * @param array $germany * @param array $island * @param array $italy */ function finale($germany, $island) { return "2:1"; } The most likely cause is that the parameter was removed, but the annotation was not. Loading history...
138		* @param string $name
139		* @param ConsumerInterface[] $consumers
140		*/
141		public function __construct(Client $client, $name, array $consumers = [])
142		{
143		$this->client = $client;
144		$this->client->register($this);
145		$this->name = $name;
146		$this->consumers = $consumers;
147		}
148
149		/**
150		* Get queue name.
151		*
152		* @return string
153		*/
154		public function getName()
155		{
156		return $this->name;
157		}
158
159		/**
160		* Get passive.
161		*
162		* @return bool
163		*/
164		public function getPassive()
165		{
166		return $this->passive;
167		}
168
169		/**
170		* @param bool $passive
171		*
172		* @return Queue
173		*/
174		public function setPassive($passive)
175		{
176		$this->passive = $passive;
177
178		return $this;
179		}
180
181		/**
182		* Get durable.
183		*
184		* @return bool
185		*/
186		public function getDurable()
187		{
188		return $this->durable;
189		}
190
191		/**
192		* Set durable.
193		*
194		* @param bool $durable
195		*
196		* @return Queue
197		*/
198		public function setDurable($durable)
199		{
200		$this->durable = $durable;
201
202		return $this;
203		}
204
205		/**
206		* Get exclusive.
207		*
208		* @return bool
209		*/
210		public function getExclusive()
211		{
212		return $this->exclusive;
213		}
214
215		/**
216		* Set exclusive.
217		*
218		* @param bool $exclusive
219		*
220		* @return Queue
221		*/
222		public function setExclusive($exclusive)
223		{
224		$this->exclusive = $exclusive;
225
226		return $this;
227		}
228
229		/**
230		* Get autoDelete.
231		*
232		* @return bool
233		*/
234		public function getAutoDelete()
235		{
236		return $this->autoDelete;
237		}
238
239		/**
240		* Set autoDelete.
241		*
242		* @param bool $autoDelete
243		*
244		* @return Queue
245		*/
246		public function setAutoDelete($autoDelete)
247		{
248		$this->autoDelete = $autoDelete;
249
250		return $this;
251		}
252
253		/**
254		* Get noWait.
255		*
256		* @return bool
257		*/
258		public function getNoWait()
259		{
260		return $this->noWait;
261		}
262
263		/**
264		* Set noWait.
265		*
266		* @param bool $noWait
267		*
268		* @return Queue
269		*/
270		public function setNoWait($noWait)
271		{
272		$this->noWait = $noWait;
273
274		return $this;
275		}
276
277		/**
278		* Get arguments.
279		*
280		* @return array\|null
281		*/
282		public function getArguments()
283		{
284		return $this->arguments;
		0 ignored issues – show Bug introduced 2016-07-07 14:17 UTC by Report Bug Copy Issue Report The property `arguments` does not exist. Did you maybe forget to declare it? In PHP it is possible to write to properties without declaring them. For example, the following is perfectly valid PHP code: class MyClass { } $x = new MyClass(); $x->foo = true; Generally, it is a good practice to explictly declare properties to avoid accidental typos and provide IDE auto-completion: class MyClass { public $foo; } $x = new MyClass(); $x->foo = true; Loading history...
285		}
286
287		/**
288		* Set arguments.
289		*
290		* @param array $arguments
291		*
292		* @return Queue
293		*/
294		public function setArguments($arguments)
295		{
296		$this->arguments = $arguments;
297
298		return $this;
299		}
300
301		/**
302		* Get ticket.
303		*
304		* @return int
305		*/
306		public function getTicket()
307		{
308		return $this->ticket;
309		}
310
311		/**
312		* Set ticket.
313		*
314		* @param int $ticket
315		*
316		* @return Queue
317		*/
318		public function setTicket($ticket)
319		{
320		$this->ticket = $ticket;
321
322		return $this;
323		}
324
325		/**
326		* Get RabbitMq specific parameter : dead letter queue.
327		*
328		* @return Queue
329		*/
330		public function getDeadLetterExchanger()
331		{
332		return $this->deadLetterExchanger;
333		}
334
335		/**
336		* Set RabbitMq specific parameter : dead letter queue.
337		*
338		* @param Exchange $exchange
339		*
340		* @return Queue
341		*/
342		public function setDeadLetterExchange(Exchange $exchange)
343		{
344		$this->deadLetterExchanger = $exchange;
345
346		return $this;
347		}
348
349		/**
350		* Get RabbitMq specific parameter : confirm.
351		*
352		* @return int
353		*/
354		public function getConfirm()
355		{
356		return $this->confirm;
357		}
358
359		/**
360		* Set RabbitMq specific parameter : confirm.
361		*
362		* @param int $confirm
363		*
364		* @return Queue
365		*/
366		public function setConfirm($confirm)
367		{
368		$this->confirm = $confirm;
369
370		return $this;
371		}
372
373		/**
374		* Get RabbitMq specific parameter : consumer_cancel_notify.
375		*
376		* @return bool
377		*/
378		public function getConsumerCancelNotify()
379		{
380		return $this->consumerCancelNotify;
381		}
382
383		/**
384		* Set RabbitMq specific parameter : consumer_cancel_notify.
385		*
386		* @param Queue $consumerCancelNotify
387		*
388		* @return Queue
389		*/
390		public function setConsumerCancelNotify(Queue $consumerCancelNotify)
391		{
392		$this->consumerCancelNotify = $consumerCancelNotify;
		0 ignored issues – show Documentation Bug introduced 2016-07-07 14:17 UTC by Report Bug Copy Issue Report It seems like `$consumerCancelNotify` of type `object<Mouf\AmqpClient\Objects\Queue>` is incompatible with the declared type `boolean` of property `$consumerCancelNotify`. 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...
393
394		return $this;
395		}
396
397		/**
398		* Get RabbitMq specific parameter : alternate_exchange.
399		*
400		* @return Queue
401		*/
402		public function getAlternateExchange()
403		{
404		return $this->alternateExchange;
405		}
406
407		/**
408		* Set RabbitMq specific parameter : alternate_exchange.
409		*
410		* @param Queue $alternateExchange
411		*
412		* @return Queue
413		*/
414		public function setAlternateExchange(Queue $alternateExchange)
415		{
416		$this->alternateExchange = $alternateExchange;
417
418		return $this;
419		}
420
421		/**
422		* Get RabbitMq specific parameter : ttl.
423		*
424		* @return int
425		*/
426		public function getTtl()
427		{
428		return $this->ttl;
429		}
430
431		/**
432		* Set RabbitMq specific parameter : ttl.
433		*
434		* @param int $ttl
435		*
436		* @return Queue
437		*/
438		public function setTtl($ttl)
439		{
440		$this->ttl = $ttl;
441
442		return $this;
443		}
444
445		/**
446		* Get RabbitMq specific parameter : max length.
447		*
448		* @return int
449		*/
450		public function getMaxLength()
451		{
452		return $this->maxLength;
453		}
454
455		/**
456		* Set RabbitMq specific parameter : max length.
457		*
458		* @param int $maxLength
459		*
460		* @return Queue
461		*/
462		public function setMaxLength($maxLength)
463		{
464		$this->maxLength = $maxLength;
465
466		return $this;
467		}
468
469		/**
470		* Get RabbitMq specific parameter : max priority.
471		*
472		* @return int
473		*/
474		public function getMaxPriority()
475		{
476		return $this->maxPriority;
477		}
478
479		/**
480		* Set RabbitMq specific parameter : max priority.
481		*
482		* @param int $maxPriority
483		*
484		* @return Queue
485		*/
486		public function setMaxPriority($maxPriority)
487		{
488		$this->maxPriority = $maxPriority;
489
490		return $this;
491		}
492
493		public function init(AMQPChannel $amqpChannel)
494		{
495		if (!$this->init) {
496		if ($this->deadLetterExchanger) {
497		$this->deadLetterExchanger->init($amqpChannel);
498		}
499
500		$parameters = [];
501		if ($this->alternateExchange !== null) {
502		$parameters['alternate-exchange'] = ['S', $this->alternateExchange->getName()];
503		}
504		if ($this->confirm !== null) {
505		$parameters['confirm'] = ['I', $this->confirm];
506		}
507		if ($this->consumerCancelNotify !== null) {
508		$parameters['consumer_cancel_notify'] = ['I', $this->consumerCancelNotify];
509		}
510		if ($this->deadLetterExchanger !== null) {
511		$parameters['x-dead-letter-exchange'] = ['S', $this->deadLetterExchanger->getName()];
512		}
513		if ($this->maxLength) {
514		$parameters['x-max-length'] = ['I', $this->maxLength];
515		}
516		if ($this->maxPriority) {
517		$parameters['x-max-priority'] = ['I', $this->maxPriority];
518		}
519		if ($this->ttl) {
520		$parameters['x-message-ttl'] = ['I', $this->ttl];
521		}
522
523		if (!$parameters) {
		0 ignored issues – show Bug Best Practice introduced 2016-07-07 14:17 UTC by Report Bug Copy Issue Report The expression `$parameters` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
524		$parameters = null;
525		}
526		$amqpChannel->queue_declare($this->name, $this->passive, $this->durable, $this->exclusive, $this->autoDelete, $this->noWait, $parameters);
527		$this->init = true;
528		}
529		}
530
531		/**
532		* Sends to RabbitMQ the order to subscribe to the consumers.
533		*/
534		public function consume()
535		{
536		$channel = $this->client->getChannel();
537
538		foreach ($this->consumers as $consumer) {
539		/* @var $consumer ConsumerInterface */
540		$channel->basic_consume($this->name,
541		$consumer->getConsumerTag(),
542		$consumer->isNoLocal(),
543		$consumer->isNoAck(),
544		$consumer->isExclusive(),
545		$consumer->isNoWait(),
546		function (AMQPMessage $msg) use ($consumer) {
547		$consumer->callback($msg);
548		},
549		$consumer->getTicket(),
550		$consumer->getArguments());
551		}
552		}
553
554		/**
555		* Unsubscribes consumers.
556		*/
557		public function cancelConsume()
558		{
559		$channel = $this->client->getChannel();
560
561		foreach ($this->consumers as $consumer) {
562		/* @var $consumer ConsumerInterface */
563		$channel->basic_cancel($consumer->getConsumerTag(),
564		$consumer->isNoWait());
565		}
566		}
567
568		/**
569		* Sends a message directly to this queue (skipping any exchange).
570		*
571		* This is a RabbitMQ only feature. Behind the scene, it will dispatch the message to the default RabbitMQ exchange.
572		*
573		* @param Message $message
574		* @param bool $mandatory
575		* @param bool $immediate
576		* @param null $ticket
577		*/
578	View Code Duplication	public function publish(Message $message, $mandatory = false,
		0 ignored issues – show Duplication introduced 2016-12-07 10:59 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
579		$immediate = false,
580		$ticket = null)
581		{
582		$channel = $this->client->getChannel();
583
584		$channel->basic_publish($message->toAMQPMessage(), '', $this->name, $mandatory, $immediate, $ticket);
585		}
586		}
587

thecodingmachine / oo-amqp-client

Push — 1.1 ( 12efad )

Queue::publish() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like