Consumer::isNoAck() - Code Metrics - Inspection of "Adding a consumer trait to create easily new consu..." - thecodingmachine/oo-amqp-client - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.0 ( ca0730...8bff85 )

by David

created 2016-07-28 10:58 UTC

Consumer::isNoAck() A

↳ Parent: Project

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

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

<?php

namespace Mouf\AmqpClient;

class Consumer implements ConsumerInterface
{
    use ConsumerTrait;

    /**
     * @var callable
     */
    private $callback;

    /**
     * Consumer constructor.
     *
     * @param callable $callback
     */
    public function __construct(callable $callback)
    {
        $this->callback = $callback;
    }

    /**
     * @return callable
     */
    public function callback($msg)
    {
        $callback = $this->callback;

        try {
            $callback($msg);

            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        } catch (RetryableExceptionInterface $e) {
            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, true);
        } catch (\Exception $e) {
            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, false);
        }
    }

    /**
     * @param callable $callback
     */
    public function setCallback($callback)
    {
        $this->callback = $callback;
    }
}


1			<?php
2
3			namespace Mouf\AmqpClient;
4
5			class Consumer implements ConsumerInterface
6			{
7			use ConsumerTrait;
8
9			/**
10			* @var callable
11			*/
12			private $callback;
13
14			/**
15			* Consumer constructor.
16			*
17			* @param callable $callback
18			*/
19			public function __construct(callable $callback)
20			{
21			$this->callback = $callback;
22			}
23
24			/**
25			* @return callable
26			*/
27			public function callback($msg)
28			{
29			$callback = $this->callback;
30
31			try {
32			$callback($msg);
33
34			$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
35			} catch (RetryableExceptionInterface $e) {
36			$msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, true);
37			} catch (\Exception $e) {
38			$msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, false);
39			}
40			}
41
42			/**
43			* @param callable $callback
44			*/
45			public function setCallback($callback)
46			{
47			$this->callback = $callback;
48			}
49			}
50

thecodingmachine / oo-amqp-client

Push — 1.0 ( ca0730...8bff85 )

Consumer::isNoAck() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like