AbstractConsumer::doReceiveMessage() - Code Metrics - Inspection of "allow micro service architecture" - jellyfishphp/jellyfish - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#32)

by Daniel

created 2020-09-02 10:02 UTC

AbstractConsumer::doReceiveMessage() A

↳ Parent: AbstractConsumer

Complexity

Conditions	3
Paths	2

Size

Total Lines	9
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

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

<?php

declare(strict_types=1);

namespace Jellyfish\QueueRabbitMq;

use Jellyfish\Queue\ConsumerInterface;
use Jellyfish\Queue\DestinationInterface;
use Jellyfish\Queue\MessageInterface;
use Jellyfish\Queue\MessageMapperInterface;
use PhpAmqpLib\Message\AMQPMessage;

abstract class AbstractConsumer implements ConsumerInterface
{
    /**
     * @var \Jellyfish\QueueRabbitMq\ConnectionInterface
     */
    protected $connection;

    /**
     * @var \Jellyfish\Queue\MessageMapperInterface
     */
    protected $messageMapper;

    /**
     * @param \Jellyfish\QueueRabbitMq\ConnectionInterface $connection
     * @param \Jellyfish\Queue\MessageMapperInterface $messageMapper
     */
    public function __construct(
        ConnectionInterface $connection,
        MessageMapperInterface $messageMapper
    ) {
        $this->connection = $connection;
        $this->messageMapper = $messageMapper;
    }

    /**
     * @param \Jellyfish\Queue\DestinationInterface $destination
     * @return \Jellyfish\Queue\MessageInterface|null
     */
    protected function doReceiveMessage(DestinationInterface $destination): ?MessageInterface
    {
        $messageAsJson = $this->connection->getChannel()->basic_get($destination->getName(), true);

        if ($messageAsJson === null || !($messageAsJson instanceof AMQPMessage)) {
            return null;
        }

        return $this->messageMapper->fromJson($messageAsJson->getBody());
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Jellyfish\QueueRabbitMq;
6
7			use Jellyfish\Queue\ConsumerInterface;
8			use Jellyfish\Queue\DestinationInterface;
9			use Jellyfish\Queue\MessageInterface;
10			use Jellyfish\Queue\MessageMapperInterface;
11			use PhpAmqpLib\Message\AMQPMessage;
12
13			abstract class AbstractConsumer implements ConsumerInterface
14			{
15			/**
16			* @var \Jellyfish\QueueRabbitMq\ConnectionInterface
17			*/
18			protected $connection;
19
20			/**
21			* @var \Jellyfish\Queue\MessageMapperInterface
22			*/
23			protected $messageMapper;
24
25			/**
26			* @param \Jellyfish\QueueRabbitMq\ConnectionInterface $connection
27			* @param \Jellyfish\Queue\MessageMapperInterface $messageMapper
28			*/
29			public function __construct(
30			ConnectionInterface $connection,
31			MessageMapperInterface $messageMapper
32			) {
33			$this->connection = $connection;
34			$this->messageMapper = $messageMapper;
35			}
36
37			/**
38			* @param \Jellyfish\Queue\DestinationInterface $destination
39			* @return \Jellyfish\Queue\MessageInterface\|null
40			*/
41			protected function doReceiveMessage(DestinationInterface $destination): ?MessageInterface
42			{
43			$messageAsJson = $this->connection->getChannel()->basic_get($destination->getName(), true);
44
45			if ($messageAsJson === null \|\| !($messageAsJson instanceof AMQPMessage)) {
46			return null;
47			}
48
49			return $this->messageMapper->fromJson($messageAsJson->getBody());
50			}
51			}
52

jellyfishphp / jellyfish

Pull Request — master (#32)

AbstractConsumer::doReceiveMessage() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like