QueueConsumer::receiveMessages() - 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

QueueConsumer::receiveMessages() A

↳ Parent: QueueConsumer

Complexity

Conditions	3
Paths	3

Size

Total Lines	16
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

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

<?php

declare(strict_types=1);

namespace Jellyfish\QueueRabbitMq;

use Jellyfish\Queue\DestinationInterface;
use Jellyfish\Queue\MessageInterface;

class QueueConsumer extends AbstractConsumer
{
    /**
     * @param \Jellyfish\Queue\DestinationInterface $destination
     *
     * @return \Jellyfish\Queue\MessageInterface|null
     */
    public function receiveMessage(DestinationInterface $destination): ?MessageInterface
    {
        $this->connection->createQueue($destination);

        return $this->doReceiveMessage($destination);
    }

    /**
     * @param \Jellyfish\Queue\DestinationInterface $destination
     * @param int $limit
     *
     * @return \Jellyfish\Queue\MessageInterface[]
     */
    public function receiveMessages(DestinationInterface $destination, int $limit): array
    {
        $receivedMessages = [];
        $this->connection->createQueue($destination);

        for ($i = 0; $i < $limit; $i++) {
            $receivedMessage = $this->doReceiveMessage($destination);

            if ($receivedMessage === null) {
                return $receivedMessages;
            }

            $receivedMessages[] = $receivedMessage;
        }

        return $receivedMessages;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Jellyfish\QueueRabbitMq;
6
7			use Jellyfish\Queue\DestinationInterface;
8			use Jellyfish\Queue\MessageInterface;
9
10			class QueueConsumer extends AbstractConsumer
11			{
12			/**
13			* @param \Jellyfish\Queue\DestinationInterface $destination
14			*
15			* @return \Jellyfish\Queue\MessageInterface\|null
16			*/
17			public function receiveMessage(DestinationInterface $destination): ?MessageInterface
18			{
19			$this->connection->createQueue($destination);
20
21			return $this->doReceiveMessage($destination);
22			}
23
24			/**
25			* @param \Jellyfish\Queue\DestinationInterface $destination
26			* @param int $limit
27			*
28			* @return \Jellyfish\Queue\MessageInterface[]
29			*/
30			public function receiveMessages(DestinationInterface $destination, int $limit): array
31			{
32			$receivedMessages = [];
33			$this->connection->createQueue($destination);
34
35			for ($i = 0; $i < $limit; $i++) {
36			$receivedMessage = $this->doReceiveMessage($destination);
37
38			if ($receivedMessage === null) {
39			return $receivedMessages;
40			}
41
42			$receivedMessages[] = $receivedMessage;
43			}
44
45			return $receivedMessages;
46			}
47			}
48

jellyfishphp / jellyfish

Pull Request — master (#32)

QueueConsumer::receiveMessages() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like