PhpAmqpLibAMQPConsumer::__construct() - Code Metrics - kreta/Kreta - Measure and Improve Code Quality continuously with Scrutinizer

PhpAmqpLibAMQPConsumer::__construct() A
last analyzed 2017-08-17 12:18 UTC

↳ Parent: PhpAmqpLibAMQPConsumer

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php

/*
 * This file is part of the Kreta package.
 *
 * (c) Beñat Espiña <[email protected]>
 * (c) Gorka Laucirica <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Kreta\SharedKernel\Infrastructure\Messaging\AMQP\PhpAmqpLib;

use Kreta\SharedKernel\Domain\Event\AsyncEventSubscriber;
use Kreta\SharedKernel\Domain\Model\Exception;
use Kreta\SharedKernel\Event\AsyncEvent;
use Kreta\SharedKernel\Messaging\AMQP\AMQPConsumer;
use PhpAmqpLib\Message\AMQPMessage;

class PhpAmqpLibAMQPConsumer implements AMQPConsumer
{
    const MSG_ACK = 1;
    const MSG_REJECT = -1;

    private $eventSubscriber;
    private $messageName;

    public function __construct(AsyncEventSubscriber $eventSubscriber, string $messageName)
    {
        $this->eventSubscriber = $eventSubscriber;
        $this->messageName = $messageName;
    }

    public function execute($message) : int
    {
        if (!$message instanceof AMQPMessage) {
            return self::MSG_REJECT;
        }
        $body = json_decode($message->body);
        if ($this->messageName !== $body->name) {
            return self::MSG_REJECT;
        }

        try {
            $this->eventSubscriber->handle(
                new AsyncEvent(
                    $this->messageName,
                    new \DateTimeImmutable($body->occurredOn),
                    json_decode(
                        json_encode(
                            $body->values
                        ),
                        true
                    )
                )
            );

            return self::MSG_ACK;
        } catch (Exception $exception) {
            return self::MSG_REJECT;
        }
    }
}


1			<?php
2
3			/*
4			* This file is part of the Kreta package.
5			*
6			* (c) Beñat Espiña <[email protected]>
7			* (c) Gorka Laucirica <[email protected]>
8			*
9			* For the full copyright and license information, please view the LICENSE
10			* file that was distributed with this source code.
11			*/
12
13			declare(strict_types=1);
14
15			namespace Kreta\SharedKernel\Infrastructure\Messaging\AMQP\PhpAmqpLib;
16
17			use Kreta\SharedKernel\Domain\Event\AsyncEventSubscriber;
18			use Kreta\SharedKernel\Domain\Model\Exception;
19			use Kreta\SharedKernel\Event\AsyncEvent;
20			use Kreta\SharedKernel\Messaging\AMQP\AMQPConsumer;
21			use PhpAmqpLib\Message\AMQPMessage;
22
23			class PhpAmqpLibAMQPConsumer implements AMQPConsumer
24			{
25			const MSG_ACK = 1;
26			const MSG_REJECT = -1;
27
28			private $eventSubscriber;
29			private $messageName;
30
31			public function __construct(AsyncEventSubscriber $eventSubscriber, string $messageName)
32			{
33			$this->eventSubscriber = $eventSubscriber;
34			$this->messageName = $messageName;
35			}
36
37			public function execute($message) : int
38			{
39			if (!$message instanceof AMQPMessage) {
40			return self::MSG_REJECT;
41			}
42			$body = json_decode($message->body);
43			if ($this->messageName !== $body->name) {
44			return self::MSG_REJECT;
45			}
46
47			try {
48			$this->eventSubscriber->handle(
49			new AsyncEvent(
50			$this->messageName,
51			new \DateTimeImmutable($body->occurredOn),
52			json_decode(
53			json_encode(
54			$body->values
55			),
56			true
57			)
58			)
59			);
60
61			return self::MSG_ACK;
62			} catch (Exception $exception) {
63			return self::MSG_REJECT;
64			}
65			}
66			}
67

kreta / Kreta

PhpAmqpLibAMQPConsumer::__construct() A last analyzed 2017-08-17 12:18 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

PhpAmqpLibAMQPConsumer::__construct() A
last analyzed 2017-08-17 12:18 UTC