QueuedMessage::fail() - Code Metrics - Inspection of "Add ability to set message as failed" - ccovey/rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 057fec...4b209d )

by Cody

created 2016-12-09 22:58 UTC

QueuedMessage::fail() A

↳ Parent: QueuedMessage

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	5
ccs	0
cts	0
cp	0
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	3
nc	1
nop	1
crap	2

<?php

namespace Ccovey\RabbitMQ;

use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Message\AMQPMessage;
use Throwable;

class QueuedMessage implements QueuedMessageInterface
{
    /**
     * @var AMQPMessage
     */
    private $message;

    /**
     * @var array
     */
    private $body;

    /**
     * @var AMQPChannel
     */
    private $queueName;

    /**
     * @var bool
     */
    private $failed = false;

    /**
     * @var Throwable|null
     */
    private $throwable;

    public function __construct(AMQPMessage $message)
    {
        $this->message = $message;
        $this->body = json_decode($this->message->body, 1);
        $this->queueName = $this->message->delivery_info['routing_key'];
    }

    public function getQueueName() : string
    {
        return $this->queueName;
    }

    public function getDeliveryTag() : string
    {
        return $this->message->delivery_info['delivery_tag'];
    }

    public function fail(Throwable $throwable = null)
    {
        $this->throwable = $throwable;
        $this->failed = true;
    }

    public function isFailed() : bool
    {
        return $this->failed;

    }

    public function getThrowable()
    {
        return $this->throwable;
    }

    public function getBody() : array
    {
        return $this->body;
    }

    public function getRawBody() : string
    {
        return $this->message->body;
    }

    /**
     * @param string $value
     *
     * @return mixed|null
     */
    public function __get(string $value)
    {
        return $this->body[$value] ?? null;
    }
}


1		<?php
2
3		namespace Ccovey\RabbitMQ;
4
5		use PhpAmqpLib\Channel\AMQPChannel;
6		use PhpAmqpLib\Message\AMQPMessage;
7		use Throwable;
8
9		class QueuedMessage implements QueuedMessageInterface
10		{
11		/**
12		* @var AMQPMessage
13		*/
14		private $message;
15
16		/**
17		* @var array
18		*/
19		private $body;
20
21		/**
22		* @var AMQPChannel
23		*/
24		private $queueName;
25
26		/**
27		* @var bool
28		*/
29		private $failed = false;
30
31		/**
32		* @var Throwable\|null
33		*/
34		private $throwable;
35
36	2	public function __construct(AMQPMessage $message)
37		{
38	2	$this->message = $message;
39	2	$this->body = json_decode($this->message->body, 1);
40	2	$this->queueName = $this->message->delivery_info['routing_key'];
41	2	}
42
43	1	public function getQueueName() : string
44		{
45	1	return $this->queueName;
46		}
47
48	1	public function getDeliveryTag() : string
49		{
50	1	return $this->message->delivery_info['delivery_tag'];
51		}
52
53		public function fail(Throwable $throwable = null)
54		{
55		$this->throwable = $throwable;
56		$this->failed = true;
57		}
58
59		public function isFailed() : bool
60		{
61		return $this->failed;
62
63		}
64
65		public function getThrowable()
66		{
67		return $this->throwable;
68		}
69
70	2	public function getBody() : array
71		{
72	2	return $this->body;
73		}
74
75		public function getRawBody() : string
76		{
77		return $this->message->body;
78		}
79
80		/**
81		* @param string $value
82		*
83		* @return mixed\|null
84		*/
85	1	public function __get(string $value)
86		{
87	1	return $this->body[$value] ?? null;
88		}
89		}
90

ccovey / rabbitmq

Push — master ( 057fec...4b209d )

QueuedMessage::fail() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like