SimpleExecuteReveiverStrategy::canPrecessMultiMessages() - Code Metrics - Inspection of "[WIP] Experimental 3.0" - eMAGTechLabs/RabbitMqBundle - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — master (#39)

by Aleksandr

created 2020-12-13 12:15 UTC

canPrecessMultiMessages() A

↳ Parent: SimpleExecuteReveiverStrategy

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php

namespace OldSound\RabbitMqBundle\ExecuteCallbackStrategy;

use OldSound\RabbitMqBundle\Declarations\QueueConsuming;
use PhpAmqpLib\Exception\AMQPTimeoutException;
use PhpAmqpLib\Message\AMQPMessage;

class SimpleExecuteReveiverStrategy extends AbstractExecuteCallbackStrategy
filter:
    dependency_paths: ["lib/*"]
{
    /** @var AMQPMessage */
    private $processingMessage;
    public function canPrecessMultiMessages(): bool
    {
        return false;
    }

    public function consumeCallback(AMQPMessage $message)
    {
        $this->processingMessage = $message;
        $this->proccessMessages([$this->processingMessage]);
    }

    public function onMessageProcessed(AMQPMessage $message)
    {
        if ($this->processingMessage !== $message) {
            throw new \InvalidArgumentException('TODO');
        }
        $this->processingMessage = null;
    }

    public function onCatchTimeout(AMQPTimeoutException $e)
    {
    }

    public function onStopConsuming()
    {
        if ($this->processingMessage) {
            $this->proccessMessages([$this->processingMessage]);
        }
    }
}

1			<?php
2
3			namespace OldSound\RabbitMqBundle\ExecuteCallbackStrategy;
4
5			use OldSound\RabbitMqBundle\Declarations\QueueConsuming;
6			use PhpAmqpLib\Exception\AMQPTimeoutException;
7			use PhpAmqpLib\Message\AMQPMessage;
8
9			class SimpleExecuteReveiverStrategy extends AbstractExecuteCallbackStrategy
			0 ignored issues – show Bug introduced 2020-12-13 12:18 UTC by Report Bug Copy Issue Report The type `OldSound\RabbitMqBundle\...ExecuteCallbackStrategy` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
10			{
11			/** @var AMQPMessage */
12			private $processingMessage;
13			public function canPrecessMultiMessages(): bool
14			{
15			return false;
16			}
17
18			public function consumeCallback(AMQPMessage $message)
19			{
20			$this->processingMessage = $message;
21			$this->proccessMessages([$this->processingMessage]);
22			}
23
24			public function onMessageProcessed(AMQPMessage $message)
25			{
26			if ($this->processingMessage !== $message) {
27			throw new \InvalidArgumentException('TODO');
28			}
29			$this->processingMessage = null;
30			}
31
32			public function onCatchTimeout(AMQPTimeoutException $e)
33			{
34			}
35
36			public function onStopConsuming()
37			{
38			if ($this->processingMessage) {
39			$this->proccessMessages([$this->processingMessage]);
40			}
41			}
42			}

eMAGTechLabs / RabbitMqBundle

Pull Request — master (#39)

canPrecessMultiMessages() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like