RabbitReceiver::consume() - Code Metrics - Inspection of "Fixing PSR12 coding style :checkered_flag:" - MuriloChianfa/Redstore-Microservice-Based - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 6765d2...f88508 )

by Murilo

created 2021-12-07 22:24 UTC

RabbitReceiver::consume() A

↳ Parent: RabbitReceiver

Complexity

Conditions	5
Paths	3

Size

Total Lines	23
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	14
c	0
b	0
f	0
dl	0
loc	23
rs	9.4888
cc	5
nc	3
nop	0

<?php

namespace Source\Core\Rabbit;

use PhpAmqpLib\Wire\AMQPWriter;
filter:
    dependency_paths: ["lib/*"]

/**
 * The rabbit receiver will be listening infinitefor messages in your queue
 *
 * the handler method can be overwrited by main class for handle the received messages
 */
abstract class RabbitReceiver extends Rabbit // implements Interface
{
    /**
     * The handler of the messages received from queue
     * @var mixed $message Received from rabbitmq queue
     */
    protected function handler($message)
    {
        // Simple print on getted message from the queue
        print_r($message->body);
    }

    /**
     * Infinite loop for listen the queue messages
     */
    protected function consume()
    {
        $callback = function ($message) {
            $this->handler($message);
        };
        $this->channel->basic_consume($this->getQueue(), 'consumer', false, $this->getReply(), false, false, $callback);

        $pid = pcntl_fork();

        if ($pid == -1) {
            echo "can i help u ?";
        } else if ($pid) {
            while (true) {
                $this->sendHeartbeat();
                sleep(10);
            }
        } else {
            while (count($this->channel->callbacks)) {
                $this->channel->wait();
            }
        }

        $this->closeConnection();
    }

    /**
     * work on PhpAmqpLib 2.9.2
     */
    private function sendHeartbeat()
    {
        $packet = new AMQPWriter();
        $packet->write_octet(8);
        $packet->write_short(0);
        $packet->write_long(0);
        $packet->write_octet(0xCE);
        $this->connection->getIO()->write($packet->getvalue());
    }
}


1			<?php
2
3			namespace Source\Core\Rabbit;
4
5			use PhpAmqpLib\Wire\AMQPWriter;
			0 ignored issues – show Bug introduced 2021-09-13 19:00 UTC by Report Bug Copy Issue Report The type `PhpAmqpLib\Wire\AMQPWriter` 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...
6
7			/**
8			* The rabbit receiver will be listening infinitefor messages in your queue
9			*
10			* the handler method can be overwrited by main class for handle the received messages
11			*/
12			abstract class RabbitReceiver extends Rabbit // implements Interface
13			{
14			/**
15			* The handler of the messages received from queue
16			* @var mixed $message Received from rabbitmq queue
17			*/
18			protected function handler($message)
19			{
20			// Simple print on getted message from the queue
21			print_r($message->body);
22			}
23
24			/**
25			* Infinite loop for listen the queue messages
26			*/
27			protected function consume()
28			{
29			$callback = function ($message) {
30			$this->handler($message);
31			};
32			$this->channel->basic_consume($this->getQueue(), 'consumer', false, $this->getReply(), false, false, $callback);
33
34			$pid = pcntl_fork();
35
36			if ($pid == -1) {
37			echo "can i help u ?";
38			} else if ($pid) {
39			while (true) {
40			$this->sendHeartbeat();
41			sleep(10);
42			}
43			} else {
44			while (count($this->channel->callbacks)) {
45			$this->channel->wait();
46			}
47			}
48
49			$this->closeConnection();
50			}
51
52			/**
53			* work on PhpAmqpLib 2.9.2
54			*/
55			private function sendHeartbeat()
56			{
57			$packet = new AMQPWriter();
58			$packet->write_octet(8);
59			$packet->write_short(0);
60			$packet->write_long(0);
61			$packet->write_octet(0xCE);
62			$this->connection->getIO()->write($packet->getvalue());
63			}
64			}
65

MuriloChianfa / Redstore-Microservice-Based

Push — master ( 6765d2...f88508 )

RabbitReceiver::consume() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like